Discussion :

[dzenakhra]

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 :

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

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.

[adiGuba]

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

[dzenakhra]

Ok ben voila mon code.

Code :

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

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.

[adiGuba]

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

Code :

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

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

[dzenakhra]

j'utilise la java 1.6