Probleme avec les tubes

Version imprimable

Voici le code d'initialisation des pipes

Code:

1
2
PipedWriter pw = new PipedWriter();
PipedReader pr = new PipedReader(pw);

Voici le code de l'ecrivain dans le pipe

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
for(int i = 0 ; i < procThread.size(); i++)
		{
			ProcessusThread proc = (ProcessusThread)procThread.get(i);
			System.out.println("eee "+proc.nomproc );
			if(proc.nomproc.equals("Accompagner clients"))
			{
				pw = (PipedWriter)proc.output.get(0);
				try
				{
					System.out.println(pw);
					pw.write(1);
					pw.flush();
 
				}
				catch(IOException e)
				{
					e.printStackTrace();
				}
			}
 
		}

et voici le code du lecteur

Code:

1
2
3
4
5
6
7
8
9
 
for(int i = 0 ; i < input.size() ; i++)
			{
				PipedReader pr = (PipedReader)input.get(i);
				 j = pr.read();
				// System.out.println("j = "+j);
				 if(j == 1)System.exit(0);
 
			}

Mais ca ne marche pas si quelqun a une explication please merci !!

28/07/2006, 09h40
in

tu instancie une seule fois pw et pr ou tu instancies pour chaque thread ?

[EDIT] pourrais tu être plus précis en ce qui concerne cette phrase :

Citation:

ça ne marche pas

;)
28/07/2006, 09h53
L4BiN

j'instancie plusieurs tube par thread. En fait j'essai de mettre en place un system de communication entre plusieurs thread (disposer en graphe).
J'instancie donc un tube pour chaque suivant d'un thread(l'entrée du tube dans le thread courant et la sortie dans le thread fils).

Ce qui ne marche pas c'est que soit pw.write(1) n'envoie rien (mais je pense que ce n'est pas ca vu qu'il n'y a pas de IOException)
soit c'est j= pr.read() qui ne lit rien mais la encore il n'y a pas d'exception. De plus d'apres l'api si il n'y a rien a lire dans le tube, pr.read() devrai retourner -1 mais dans mon cas j = pr.read() reste toujours a la valeur initial de j = 0 (comme si l'instruction j = pr.read ne servait a rien).
28/07/2006, 10h16
in

bon alors je n'ai jamais utilisé ça donc je lance des trucs un peu au hasard. On ne sait jamais.

pourquoi, dans ta boucle de lecture tu instancies à nouveau pr ? enfin pourquoi tu ne fais pas comme dans la boucle d'écriture ?

Bon comme je suis un néophyte là-dedans ... as tu regardé le tuto sur java.io ? Il y a un exemple d'utilisation et il y a quelques différences avec ton bout de code.

bonne chance ;)
28/07/2006, 10h44
L4BiN

en fait dans la boucle je récupère les pr (pipedRead) que j'ai stocker dans des arrayList.

Mais en fait j'ai trouver la solution, ce n'etait pas à cause des tubes, c'etait a cause d'une autre partie de mon prog.

Mais je te remercie qd meme a bientot ++