Mettre en pause plusieurs Jprogress Bar

Version imprimable

27/01/2011, 14h55
Cedric3111

Mettre en pause plusieurs Jprogress Bar
Salut tout le monde,
Je développe actuellement un aspirateur de site multithread. J'associe chaque thread d'aspiration à une JprogressBar afin de visualiser l'état de l'avancement. Ceci marche correctement. Cependant je voudrai implémenter un bouton "Pause" voici ce que j'ai fait :
Code:

1 2 3 4 public void setPause(ArrayList<Thread> list) { for(Thread th : list) { synchronized(th) {th.wait();} }
IL ne lit que le premier élément de ma liste qui correspond à ma première JprogressBar et freeze mon interface. Quand j'exécute en mode debug, on voit qu'il reste bloqué sur th.wait() et qu' il n'en sort jamais.

Si je ne met pas le synchronized j'obtient il jette l'exception suivante :
Exception in thread "AWT-EventQueue-0" java.lang.IllegalMonitorStateException: current thread not owner.

Quelqu'un a déjà eut ce problème?

Cdt
Cédric
27/01/2011, 15h57
tchize_

je crosi que vous n'avez pas bien lu la documentation ce que fait wait :)
ca met en pause le thread courant (donc ici le thread de l'edt) jusqu'à ce qu'un autre thread appelle a méthode notify() sur le même objet.
27/01/2011, 16h16
Cedric3111

Bin le souci c que je vois pas comment appeler une méthode notify() en sachant que tout est bloqué. Initialement c'est ce qui est prévu : lorsqu'on clique sur le bouton "pause" toutes les ProgressBar s'arrêtent, et lorsqu'on clique sur "resume", la progression reprend la où elle s'était arrêtée.
Mais comme tout est bloqué je ne peux pas cliquer sur le bouton "resume" pour exécuter notifyAll(). Je sais pas si je m'explique bien en fait :s
27/01/2011, 17h13
Cedric3111

Cela signifie-t-il qu'il faut détacher la thread de l'interface?
Si oui comment faire?
27/01/2011, 19h56
tchize_

tout n'est pas bloqué, seule votre interface est bloquée.

Si vous voulez que les threads attendent, c'est dans les threads qu'il faut mettre le code gérant la pause. Votre code n'aura qu'à faire, pour la mise en pause:

leThread.setPause(true);

et pour la remise en route
leThread.setPause(false);

quand vous appelez wait/notify/notifyAll, l'objet sur lequel vous l'appelez n'est qu'un sémaphore qu'on va lever (notify/notifyAll) ou qu'on va attendre (wait). Donc c'est toujours le thread à mettre en pause qui appelle wait() et le thread qui réveille l'autre qui appellera notify/notifyAll.
27/01/2011, 20h07
Cedric3111

MErci beaucoup pour cette réponse. Ce qui me permet d'embrayer sur la prochaine question : comment fait on lorsqu'on a un pool de thread?

JE voulais aussi savoir quel est le contenu de la methodes isPause(true).

Voici 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
package grabberLayer.threadpool;
 
public class ThreadWorker extends Thread{
 
	private ThreadPool pool;
 
	public ThreadWorker(ThreadPool pool)
	{
		this.pool = pool;
	}
 
	public void pause() {
		try {
			synchronized (this) {
				this.wait();
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
 
	public void run()
	{
		while(true)
		{
			//blocks until job
			Runnable job=pool.getNext();
			if(null==job)
				return;
			try
			{
				pool.incrementActiveThread();
				job.run();
				pool.decrementActiveThread();
			}
			catch(Exception e){
				System.out.println("Job exception: "+e);
			}
		}
	}
}

Et malgré ca freeze toujours l'interface :s

Code:

1
2
3
4
5
6
7
8
	public void pause() {
		try {
			synchronized (this) {
				this.wait();
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

vous n'avez rien changé à votre code, et vous n'avez toujours pas compris que wait arrête le thread COURANT, pas celui dont vous appelez la méthode. votre méthode setPause doit ressembler à ça

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
boolean pause= false;
Object semaphore = new Object();
public void pause() {
   synchronized(semaphore) {
       pause=true;
   }
}
 
public void resume(){
   synchronized(semaphore){
       pause=false;
       semaphore.notify();
   }
}
public void run(){
//......
 synchronized(semaphore){
     if (pause){
         semaphore.wait();
     }
 }
}