[JDialog + Thread] Arret d'un thread

Version imprimable

Bonjour,

Je suis sur un problème d'arrêt de thread.
J'ai consulté la FAQ, mais il doit me manquer quelque chose.

J'ai un JDialog qui contient son propre thread. J'ai ajouté un windowLinstener pour qu'à la fermeture je puisse fermer cette JDialog, mais également fermer le thread associé.

Le code épuré donne :

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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
public class jpPopup extends JDialog implements Runnable,WindowListener
{
	private Thread t;
	private boolean isTRun;
	private boolean isPlay;
	private boolean isStop;
 
	public jpPopup()
	{
		super();
		this.isPlay=false;
		this.isStop=false;
		this.isTRun=true;
		this.pack();
		this.setVisible(true);
		this.addWindowListener(this);
 
		this.t=new Thread(this);
		this.t.start();
	}
 
	public void run()
	{
		while(this.isTRun)
		{
			try
			{
				System.out.println("(jpPopupSon - run) isPlay : "+this.isPlay+" -- isStop : "+this.isStop);
 
				if(this.isPlay)
					testStop();
				else
				{
					//TRAITEMENT
					this.isPlay=true;
				}
 
				Thread.sleep(1000);
			}
			catch(InterruptedException e)
			{
				System.out.println("(jpPopupSon - InterruptedException)");
				e.printStackTrace();
				this.isTRun=false;
			}
		}
	}
 
 
	public synchronized void testStop() throws InterruptedException
	{
		System.out.println("(jpPopupSon - testStop)");
		if(this.isStop)
			throw new InterruptedException();
	}
 
 
	public synchronized void tStop()
	{
		this.isStop=true;
	}
 
	public void windowClosing(WindowEvent e)
	{
		System.out.println("(jpPopupSon - windowClosing)");
		tStop();
	}
}

Merci d'avance

Salut,

Déclares les variables partagée en volatile, où alors synchronise chacun de leurs accès, sinon il est possible de ne pas voir les modifications affectées depuis un autre thread.

Au passage essayes de limiter au maximum le partage de données entre les threads.

Au passage il serait préférable d'utiliser le mécanisme d'interruption des threads. C'est fait pour cela :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 public void run() { final Thread current = Thread.currentThread(); while (current.isInterrupted() == false) { try { System.out.println("(jpPopupSon - run) "); // TRAITEMENTS Thread.sleep(1000); } catch (InterruptedException e) { System.out.println("(jpPopupSon - InterruptedException)"); e.printStackTrace(); } } System.out.println("Fin du thread"); } public void tStop() { this.t.interrupt(); }
a++

Je ne connaissais pas ce mot clé "volatile".

Mon code est devenu :

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
47
48
49
50
51
52
53
54
 
public class jpPopup extends JDialog implements Runnable,WindowListener
{
	private volatile Thread t;
	private volatile boolean isPlay;
 
	public jpPopup()
	{
		super();
		this.isPlay=false;
		this.pack();
		this.setVisible(true);
		this.addWindowListener(this);
 
		this.t=new Thread(this);
		this.t.start();
	}
 
	public void run()
	{
		while(this.t.isInterrupted() == false)
		{
			try
			{
				System.out.println("(jpPopupSon - run) isPlay : "+this.isPlay);
 
				if(!this.isPlay)
				{
					//TRAITEMENT
					this.isPlay=true;
				}
 
				Thread.sleep(1000);
			}
			catch(InterruptedException e)
			{
				System.out.println("(jpPopupSon - InterruptedException)");
				e.printStackTrace();
			}
		}
	}
 
 
	public void tStop()
	{
		this.t.interrupt();
	}
 
	public void windowClosing(WindowEvent e)
	{
		System.out.println("(jpPopupSon - windowClosing)");
		tStop();
	}
}

J'ai essayé avec final Thread current = Thread.currentThread(); à la place du this.t, mais ça ne change rien.
D'un point de vue "syso", je vais bien dans tStop(), mais je ne boucle pas dans le while.

Citation:

Envoyé par Paniez

J'ai essayé avec final Thread current = Thread.currentThread(); à la place du this.t, mais ça ne change rien.

Définir le thread en variable locale permet de s'éviter de partager une variable supplémentaire ;)
Et donc d'éviter l’utilisation d'un volatile supplémentaire (ce qui implique que la JVM ne pourra pas mettre en cache la valeur)

Citation:

Envoyé par Paniez

D'un point de vue "syso", je vais bien dans tStop(), mais je ne boucle pas dans le while.

Je n'y avais pas fait attention mais ton catch() est à l'intérieur de ton while()... alors que ce devrait être le contraire (l'interruption doit mettre fin à la boucle) :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 public void run() { final Thread thread = Thread.currentThread(); try { while (thread.isInterrupted() == false) { System.out.println("(jpPopupSon - run) isPlay : " + this.isPlay); if (!this.isPlay) { // TRAITEMENT this.isPlay = true; } Thread.sleep(1000); } } catch (InterruptedException e) { // Est-ce vraiment utile ? // On est dans un cas de sortie "normale" : System.out.println("(jpPopupSon - InterruptedException)"); e.printStackTrace(); } }
a++

18/01/2011, 14h48
Paniez

Ca fonctionne niquel.

Encore merci