Discussion :

[be_tnt]

Voilà,

J'ai une classe qui est chargé d'initializer les composants de mon application. Elle initialise entre autres une blocking queue, un dispatcher lié à la blocking queue et un ensemble de threads (handler) traitant de requêtes reçu du dispatcher.

Cela donne:
<BlockingQueue> <--- Dispatcher ---> Handler 1
---> Handler 2
---> ....

Chaque requête écrite dans la blocking queue est récupéré par le dispatcher. Celui-ci sélectionne alors un handler de libre et lui envoie la requête à traiter.

Chaque handler ne traite qu'une requête à la fois.

Je suppose que dans mon handler, je peux utiliser un objet sur lequel écoute le handler. Il devra attendre jusqu'à ce que la ressource soit dispo (synchronisation).

Maintenant je voudrais aussi que mon monitor puisse connaître l'état de chaque thread qu'il a démarré. Est-ce possible? Si oui , comment se fait l'implémentation? Est-ce que le monitor peut envoyer un signal aux threads crées (du style: kill toi )

[spekal]

Il y a les formes classiques du style Thread.isAlive(). Tu peux également préparer tes propres formes de Thread, simplement en dérivant la classe Thread. Tu peux même te créer tes propres groupes de threads, avec ThreadGroup.

Et en java 5, tu as également le paquetage java.util.concurrent, avec lequel tu peux construire des pools.

Veux-tu d'autres précisions ?

[adiGuba]

Salut,

Je suppose que dans mon handler, je peux utiliser un objet sur lequel écoute le handler. Il devra attendre jusqu'à ce que la ressource soit dispo (synchronisation).

Si tu utilises les BlockingQueue pour passer les objets d'un thread à l'autre tu ne devrait pas avoir de problème de synchronisation, puisque c'est déjà géré...

Maintenant je voudrais aussi que mon monitor puisse connaître l'état de chaque thread qu'il a démarré. Est-ce possible? Si oui , comment se fait l'implémentation?

Avec Java 5.0 il suffit d'utiliser la méthode getState()...

Est-ce que le monitor peut envoyer un signal aux threads crées (du style: kill toi )

Tu peux utiliser la méthode interrupt() pour cela. Bien sûr il faut que ton Thread gère cela correctement, en vérifiant la valeur retourné par isInterrupted(), et en traitant les InterruptedException des méthodes bloquantes...

a++

[be_tnt]

Merci pour les infos.

Je vais essayer un peu tout ça pour voir