Communication entre thread

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

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:

---

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

---

Thread 1 :

Code:

---

queue.put( object );

---

Thread 2 :

Code:

---

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

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