[THREAD]wait() sur un processus autre que celui courant

Bonjour à tous,

Je travaille actuellement sur un projet et je dois m'occuper de la gestion de la concurrence.

J'ai une classe principale "Controller" qui gere le lancement et la mise en pause de processus. Mes processus sont des instances d'une classe "worker" qui hérite de Thread.

Controller lance les processus (avec start()) et ceux-ce s'arretent (avec wait()), Controller les débloque un par un (avec un notify()). Seulement les processus ont un temps maximal pour s'executer. Si ce temps est atteint, je dois l'arreter et il reprendra son execution la ou il s'est arrêté au prochain tour.

Mon problème est que lorsque Controller tente d'arrêter un processus au bout d'un certain temps, ce n'est pas un Worker qui s'arrete mais Controller lui-même.

Est-ce mon utilisation de wait() et notify() qui est fausse ou faut-il passer par une autre facon de faire?


Merci d'avance pour vos réponses.


P.S. j'ai mis un code d'exemple que j'utilise pour tester la gestion que je dois faire

En fait lorsque tu veux arrêter un Worker tu fais:

Code:

---

1 2 3

synchronized (wrk[i]) { wrk[i].wait(); }

---

Vu que de son coté le worker fait:

Code:

---

1 2 3 4 5 6 7 8 9 10

public void askNextState() { synchronized (this) { try { System.out.println("-" + getName()+"- Sleeping"); wait(); } catch (InterruptedException e) { e.printStackTrace(); } } }

---

He bien le controller attend la fin d'un worker qui lui même attend sur un wait. Je dirai que tu as un beau dead lock ;)

Sinon si tu veux interrompre ton worker tu devrais faire

Code:

---

wrk[i].interrupt()

---

Et dans ton code gérer l'exception InterruptionException au lieu de l'ignorer.

De plus, dans ton worker, si tu fais pas mal de boulot dans une boucle tu peux tester si le controller veux t'interrompre avec isInterrupted.