Discussion :

[mehdiyassin]

bonjour, qd je lance le programme qui suit j'ai tjs la meme erreur qui vient: "pipe broken" j'ai l'impression que le "main" s'arrete avant que consumer lise ds le pipe

quelqu'un peut m'aider???

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
class Test
{
	public static void main (String args [])
 
  {
 
              PipedInputStream pin=new PipedInputStream();
          PipedOutputStream pout=new PipedOutputStream(pin);
 
          Producer producer=new Producer(pout);
          Consumer consumer=new Consumer(pin);
 
          producer.start();
          consumer.start();
 
     }

[staul]

Je te confirme que le main s'arrete bien avant les fils. Je suppose que producer et consumer sont des Thread.

Ta classe Test instancie les deux threads ci-dessus, elle les lance dans deux processus differents et ensuite elle s'arrete. MAis c'est pa sun probléme. Elle peut s'arreter dans deux cas :

Class Thread

The exit method of class Runtime has been called and the security manager has permitted the exit operation to take place.

All threads that are not daemon threads have died, either by returning from the call to the run method or by throwing an exception that propagates beyond the run method.

A mon avis c'est ton producer qui aprés avoir produit s'arrete sans attendre le consumer. Et là ça peut poser probléme.

[mehdiyassin]

qu'est ce que je dois faire alors ??

[staul]

Si c'est ça il faut que le producteur se mette en attente aprés avoir terminé d'écrire. De même que le lecteur doit attendre que le producteur termine d'ecrire.

Pour resumer, il faut synchroniser tes threads pour ne pas que l'un des deux s'arrete tant que l'autre n'a pas terminé. Et la ça depend de ton code.

Si tu veux simplement mettre en attente le producteur tu peux essayer ça :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
Consumer consumer=new Consumer(pin); 
Producer producer=new Producer(pout,consumer);

puis dans le code de Producer, à la fin de public void run() :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
public void run() {
....
// on attend que l'autre thread se termine
consumer.join();
}

Maintenant, ç'est pas genial puisque seul le producteur attend le lecteur. C'est pas complétement synchronisé. Le lecteur peut se terminer avant que le producteur termine d'ecrire et donc tu perds des données.

[Alwin]

Juste un petit conseil pour éviter une dépendance de classes, défini le constructeur de ton Producer comme suit :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

public Producer(OutputStream out, Thread consumer) {...

et non

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

public Producer(OutputStream out, Consumer consumer) {...

[mehdiyassin]

merci beaucoup !!
ca marche nickel!!!!

bonne journée