arreter Thread avec interrupt()

Bonjour,

voici le code de la classe utilisée par mon Thread:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 public class MonThread implements Runnable { public MonThread(){ ... } @Override public void run(){ while(!Thread.currentThread().isInterrupted()){ ... aucune fonctions bloquantes dans la boucle } } }
=> j'ai beau lancer un .interrupt(), ça n'arrête pas mon Thread : ce n'est pas comme ça qu'on fait ?

Pourquoi ne pas simplement utiliser un boolean

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
public class MonThread implements Runnable {
 
	private boolean stop = false;
	public MonThread(){
		...
	}
 
	public void arretter(boolean stop){ this.stop = stop;}
 
	@Override
	public void run(){
 
		while(!stop){
			... aucune fonctions bloquantes dans la boucle	
 
		}
 
	}
 
}

A noter que pour avoir quelque chose qui fonctionne correctement en multithread, il faudrait déclarer la variable stop volatile :

Code:

private volatile boolean stop = false;

Citation:

Envoyé par Ivelios

Pourquoi ne pas simplement utiliser un boolean

La classe Thread contient déjà une methode pour arrêter les Thread (qui est .interrupt()) alors pourquoi vouloir en créer d'autre ? => ça doit bien être possible de faire ça, non ?

Salut,

Citation:

Envoyé par boboss123

La classe Thread contient déjà une methode pour arrêter les Thread (qui est .interrupt()) alors pourquoi vouloir en créer d'autre ? => ça doit bien être possible de faire ça, non ?

En effet cela fonctionne parfaitement avec interrupt().

Maintenant ton code comporte le strict minimum, et mis à part "ca marche pas" on ne sait rien du tout...

a++

1) t'es sûr d'arréter le bon Thread ?
2) es tu sûr qu'il n'y pas de méthode dans ta boucle qui sont réveillées par l'interruption et qui repositionne ensuite l'indicateur d'interruption (ex. Thread.sleep)

Citation:

Envoyé par professeur shadoko

1) t'es sûr d'arréter le bon Thread ?
2) es tu sûr qu'il n'y pas de méthode dans ta boucle qui sont réveillées par l'interruption et qui repositionne ensuite l'indicateur d'interruption (ex. Thread.sleep)

J'ai un Thread.Sleep dans ma boucle : il faut faire quoi si cette methode repositionne le flag ?

il faut traiter le flag avant. Interrupt va positionner le flag et arreter la fonction blocante en cours en déclenchant un interruptedException. Si tu ne traite pas correctement cette exception, (tu l'ignore ou tu la loggue seulement par exemple) et que t'appelle ensuite d'autres méthodes, celles-ci risquent de repositionner le flag. Montre nous ton code qu'on puisse t'aider! C'est tout l'intéret d'utiliser ton propre boolen, c'est que t'es sur que les méthodes de l'api ne vont pas chipoter avec.

Citation:

Envoyé par boboss123

J'ai un Thread.Sleep dans ma boucle : il faut faire quoi si cette methode repositionne le flag ?

Si ton thread est dans un etat slep(), la methode interrupt() va faire que sleep() va lancer une interruptedexception mais va ensuite remettre interrupted a false. Donc il faut que tu verifies cela dans le catch du sleep() pour arreter ton traitement.

Ok merci beaucoup,

Je comprend mieux l'intérêt de créer sa propre methode d'arrêt...

Pour ma culture perso, j'aimerais comprendre comment il faudrait que je fasse si je voulais ne pas créer de methode stop().

J'arrive donc a arrêter mon thread comme ceci :
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 public class MonThread implements Runnable { public MonThread(){ ... } @Override public void run(){ while(!Thread.currentThread().isInterrupted()){ ... aucune fonctions bloquantes dans la boucle ... aucun appel a Thread try { Thread.sleep(pGapTimeTX); } catch (InterruptedException e) { // TODO Auto-generated catch block //e.printStackTrace(); Thread.currentThread().interrupt(); } } } }
=> si j'ai bien compris, si je fais un sleep sur mon thread, ça va me générer une exception et donc ça va m'arrêter mon thread, non ? que faut-il faire alors ?

Code:

1
2
3
4
5
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				//e.printStackTrace();
				break;
			}

Citation:

Envoyé par boboss123

=> si j'ai bien compris, si je fais un sleep sur mon thread, ça va me générer une exception et donc ça va m'arrêter mon thread, non ? que faut-il faire alors ?

Il ne faut pas traiter l'exception à l'intérieur de ta boucle, sinon c'est normal que le thread continue son travail comme si de rien n'était puisque tu l'as ignoré...

Il suffit de reporter le traitement des exceptions en dehors de la boucle :
Code:

1 2 3 4 5 6 7 8 9 10 11 public void run(){ try { while(!Thread.currentThread().isInterrupted()){ // ... Thread.sleep(pGapTimeTX); } } catch (InterruptedException e) { // fin de traitement par interruption } }
a++

ok merci

oups je me suis emmêlé les pinceaux... finalement, il me semble que la méthode que j'ai utilisée est correcte : en faisant, Thread.currentThread().interrupt(); je remets le flag Thread.currentThread().isInterrupted() à true et donc je sorts de la methode à la fin de ma boucle... c'est un peu plus long que d'utiliser un break; ou un catch à l'extérieur de la boucle mais ça peut etre utile si je veux etre sur que ma boucle soit complètement exécutée avant de sortir du Thread