Discussion :

[MinsK]

Salut à tous,

Je voudrais réaliser une application basique avec 2 threads: 1 producteur, 1 consommateur.
Je lance le producteur avec un bouton Start, idem pour le consommateur.
Et j'ai un bouton Pause pour chacun.

Sans utiliser les boutons pause, ca marche nikel. Dés que je touche un bouton pause ca plante: dans la console ca marche tjrs jusqu'a la fin du programme mais sur l'applet je peux plus rien toucher et ca plante méchant.

Voici la partie de mon applet qui s'ocuppe des boutons:

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
public synchronized void actionPerformed(ActionEvent event) {
		Object source = event.getSource();
 
		if      (source == b_startCustomer)    {
			System.out.println("b1");
			newArrival.start();
		}
		else if (source == b_pauseCustomer)  {
			System.out.println("b2");
			try {
				if (arrivalsPaused==false){
					newArrival.pauseArrivals();
					arrivalsPaused=true;
				}else{
					newArrival.resumeArrivals();
					arrivalsPaused=false;
				}
 
			} catch (InterruptedException e) {
				// TODO Bloc catch auto-généré
				e.printStackTrace();
			}
		}
		else if (source == b_startTill) {
			System.out.println("b3");
			newDepartures.start();
		}
		else if (source == b_pauseTill) {
			System.out.println("b4");
			try {
				if (departuresPaused==false){
					newDepartures.pauseDepartures();
					departuresPaused=true;
				}else{
					newDepartures.resumeDepartures();
					departuresPaused=false;
				}
 
			} catch (InterruptedException e) {
				// TODO Bloc catch auto-généré
				e.printStackTrace();
			}
		};
 
		repaint();
	  }

Voici la partie s'occupe de la pause et resume dans le producteur (c pareil pour le consommateur):

Code :

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

1
2
3
4
5
6
7
public synchronized void pauseArrivals() throws InterruptedException{
		wait();
	}
 
	public synchronized void resumeArrivals(){
		notify();
	}

[MinsK]

Aucune idée?!
Mon code parait-il bon ?

[Deadpool]

Si j'ai bien compris ton code tu procède ainsi :

- pour la pause: appel de la méthode wait du thread que tu veux mettre en pause.

-pour le resume: appel de la méthode notify du même thread soit celui que tu veux réveiller.

Si c'est bien ça alors on est en face d'un problème...

Un thread endormi par un wait ne peux se réveiller lui-même en appelant notify. C'est à un autre thread non endormi d'appeler le notify de manière à pouvoir réveiller le thread endormi.

J'espère que je suis clair...

[xavlours]

Moi je trouve ca bizarre que ca marche en mode console :
- tu crées tes threads, tout va bien.
- lors de l'appel des méthodes pause(), c'est le thread graphique qui fait le wait(). Normalement, ton interface graphique devrait se figer.

Ton programme doit etre construit ainsi :

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
public void actionPreformed(ActionEvent e) {
 
  if(event.getSource().equals(b_start))
    monthread.start();
  else if(event.getSource().equals(b_pause))
    monthread.triggerPause();
}
 
Class MonThread extends Thread {
 
  private boolean paused = false;
 
  public void run() {
    while(true) {
      synchronized(this) {
        while(paused) {
          try {this.wait(); } //catch ...
        }
      }
      // le reste du run ...
    }
  }
 
  public void triggerPause() {
    synchronized(this) {
      paused = !paused;
      if(!paused)
        this.notify();
    }
  }
}

Comme ca, le thread graphique indique a monthread qu'il doit s'arreter en appelant triggerPause, c'est monthread qui appelle wait() sur lui meme, et c'est le thread graphique qui appelle notify() sur le meme objet.

[MinsK]

Je comprend ce que vous voulez m'expliquer: si un thread est endormie, il peut pas se reveiller tout seul. Par contre il peut s'endormir tout seul.

Mais en lisant ton code xavlours j'ai du mal à voir une différence avec ce que j'avais ecrit: pour le notify() c'est une méthode comme mon resume...() qui fait un le notify() sur this. Et pour le wait() il est appelé indirectement et dans le run() mais ca reste this (le thread lui même) qui lance le wait() non??!

Bref, même si je l'ai pas tout à fait compris, ton code marche nikel!

Merci.