Discussion :

[JFPS Soft]

Bonjour,

J'essaye de faire communiquer deux thread à l'aide de pipe. L'un ecrit des données et l'autre les lit


Thread1 ( thread qui ecrit )
PipedOutputStream iPOS = new PipedOutputStream()
Création de Thread2 avec iPOS en apramètre du constructeur
ObjectOutputstream iOOS = new ObjectOutputstream(iPOS)

Thread2 ( thread qui lit )
PipedIntputStream iPIS = new PipedIntputStream (iPOS)
ObjectIntputstream iOIS = new ObjectIntputstream (iPIS)

Jusque là, tout ce passe bien.. les flux sont bien créé.

Je cherche à ce que le thread2 ait le comportement suivant :
il est à l'écoute du pipe et dès qu'il recoit un message, il effectue un traitement et il se remet à l'écoute d'un eventuel message ...et tant le thread ne recoit pas de message, il ne fait rien....

Je pensais que l'appel à iOIS.readObject() me permettrait de réaliser cette mise à l'écoute.
Le premier message recu et bien traité :
exemple de message :
SYS com traite :Message de :SYS vers BA contenu :utils.Evenement@64c34e

Mais quand dans ma boucle, le thread se repositionne à l'écoute (donc en attente du message n°2), j'ai le message suivant



java.io.IOException: Write end dead
at java.io.PipedInputStream.read(Unknown Source)
at java.io.ObjectInputStream$PeekInputStream.peek(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.peek(Unknown Source)
at java.io.ObjectInputStream$BlockDataInputStream.peekByte(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at communication.JFPSCommunicationManager.run(JFPSCommunicationManager.java:241)

Faut-il faire une action particuliere apres un readObject pour pouvoir se repositiooner à l'écoute.

J'ai consulté des docs mais je n'ai pas trouvé ma solution. Je vous remercie d'avance de votre aide.

[adiGuba]

Salut,


Il me semble que ce type d'erreur peut survenir si le buffer de ton PipedInputStream est plein (mais je ne suis pas sûr de ca il y a de forte chance que je me trompe).

Maintenant il semble que tu désires seulement "passer" des objets d'un thread à l'autre, et je ne penses pas que ce soit la meilleure solution (obligation de sérializer/désérialiser les objets, donc il seront alloué deux fois...).

Si tu utilises Java 5.0, tu peux directement utiliser une BlockingQueue

Initialisation :

Code :

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

BlockingQueue<Object> queue = new LinkedBlockingQueue<Object();

Thread 1 :

Code :

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

queue.put( object );

Thread 2 :

Code :

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

Object object = queue.take();

Tu n'a rien à gérer mis a part les InterruptedException, toutes la synchronisation est déjà géré (si il n'y a rien, take() mettra ton thread 2 en attente)...


Enfin si tu n'utilises pas encore Java 5.0, tu peux faire la même chose avec une collection normal en utilisant des bloc synchronisé et des wait() et des [b]notify()[/n], mais c'est un peu plus complexe à gérer...

a++

[JFPS Soft]

Merci je vais essayer ta solution car j'ai environ une trentaine de thread qui commnuiquent entre eux...et entre les Piped..et les Object... ca commence à faire du monde...

Je ne connaissais pas les blockingQueue qui devraient me simplifier la tache...

Merci beaucoup