Producteur consommateur thread semaphore

Version imprimable

23/02/2011, 14h36
KptN22

1 pièce(s) jointe(s)

Producteur consommateur thread semaphore

Bonjour,

Mon problème est le suivant:
3 producteurs envoient un fichier à des vitesses différentes (respectivement 1,2,4 fichier/s) à un buffer de taille 5, ils ont chacun 7 fichiers à envoyer
1 consommateur récupère dans le buffer (1fichier/s).

Mon implémentation est faite avec des sémaphores binaire pour ne pas utiliser la synchronisation.

Je vous poste le code, je ne comprends pas où est mon erreur.
Merci
23/02/2011, 15h21
Génoce

Bonjour,

Essaie de localiser les bouts de codes importants et / ou qui posent problème et de les poster directement dans le thread à l'aide des balises CODE.
De plus, tente de détailler un peu plus ton problème.
Sans cela, je doute que quelqu'un ai la motivation de jeter un œil à tes sources.

Le problème est l'implémentation du consommateur, je voudrais qu'à la fin le buffer partagé soit vide et qu'il ait récupéré 21 produits (soit 7 issus de chaque producteur)

voila pour la partie code

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
public void run() {
		while (true) {
			try {
				Thread.sleep( this.time );
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			tray.take();
			nbLettersReceived++;
			System.out.println("A letter has been removed by the manager ");
			System.out.println("Number Letters received: "+nbLettersReceived);
			tray.printLetters();
			System.out.println("------------------------------------------------");
			try {
				Thread.sleep( this.time );
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	  }