Discussion :

[L4BiN]

Voici le code d'initialisation des pipes

Code :

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

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

Voici le code de l'ecrivain dans le pipe

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
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 :

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

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 !!

[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 :

ça ne marche pas

[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).

[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

[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 ++