Probleme avec Les lock et les condition

Bonjour
j'ai le code suivant que je voulais utiliser pour produire une chose proche du l'algorithme du rendez-vous, on utilisant un lock et sa condition le code est le suivant :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

... Lock veroux4 = new ReentrantLock(); Condition tousIci = veroux4.newCondition(); ... veroux4.lock(); nombre++; if(nombre==5){ System.out.println("Le processus n° "+num+" débloque les autres processus."); tousIci.signalAll(); } else{ try { System.out.println("Le processus n° " + num + " attend les autre processus."); tousIci.await(); System.out.println("Le processus n° " + num + " est débloquer."); } catch (InterruptedException ex) { Logger.getLogger(MathThread.class.getName()).log(Level.SEVERE, null, ex); } } veroux4.unlock();

---

les 4 premiers threads seront bloquer mais les 5 quant il passe et il exécute tousIci.signalAll(), ces thread là ne sont pas réveillés, alors qui le seule thread qui passe est ce-lui qui a exécute tousIci.signalAll(), et n'a pas exécuté tousIci.await();

je sais que les barrières cycliques seront plus performantes, mais je veux surtout savoir la raison de ce dis-fonctionnement.
Merci pour votre aide.

Salut,


Cela me semble pourtant correct.
Tu aurais un exemple de code complet (compilable en l'état) qui reproduirait le problème ?

a++

PS : Il faudrait un try/finally pour libérer le lock ;)

Ok ben voila mon code.

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46

import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.logging.Level; import java.util.logging.Logger;   public class MathThread extends Thread {   int num;   static Lock veroux4 = new ReentrantLock(); static Condition tousIci = veroux4.newCondition(); static boolean[] lignes; static int etape; static int nombre; static boolean wait=true; /** Creates a new instance of MathThread */ public MathThread(int num) {   this.num=num;     }   public void run() {   veroux4.lock(); nombre++; if(nombre==5){ System.out.println("Le processus n° "+num+" débloque les autres processus."); tousIci.signalAll(); } else{ try { System.out.println("Le processus n° " + num + " attend les autre processus."); tousIci.await(); System.out.println("Le processus n° " + num + " est débloquer."); } catch (InterruptedException ex) { Logger.getLogger(MathThread.class.getName()).log(Level.SEVERE, null, ex); } } veroux4.unlock();   } }

---

j'espère que vous aller comprendre le problème.

En lançant 5 threads à la suite j'ai bien le bon résultat :

Code:

---

1 2 3 4 5 6 7 8 9

Le processus n° 0 attend les autre processus. Le processus n° 1 attend les autre processus. Le processus n° 2 attend les autre processus. Le processus n° 3 attend les autre processus. Le processus n° 4 débloque les autres processus. Le processus n° 0 est débloquer. Le processus n° 1 est débloquer. Le processus n° 2 est débloquer. Le processus n° 3 est débloquer.

---

Pour info tu utilises quelle version de Java ??

a++

j'utilise la java 1.6