Discussion :

[®om]

Salut,

Je rencontre un problème auquel je ne trouve pas de solution propre.
Je souhaite exécuter une action toutes les x secondes. Cette action consiste à tester une condition, et si elle est fausse (ou vraie, ça dépend si on prend la négation), alors il faut arrêter d'exécuter l'action toutes les x secondes.

Voici l'exemple, mais qui évidemment ne marche pas:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
final ScheduledFuture<?> future = executor.submit(new Runnable() {
	@Override
	public void run() {
		boolean condition = false; //remplacer par la condition
		if (condition) {
			future.cancel(false);
		} else {
			//code
		}
	}
}, 10, 10, TimeUnit.SECONDS);

Forcément, on ne peut pas faire future.cancel(), car il peut ne pas être initialisé.

Le problème, c'est que pour s'annuler, l'action doit connaître le future qui est renvoyé lorsqu'on met le runnable en paramètre de submit (en gros il y a un cycle de causalité).

Avez-vous une solution?

[®om]

Bon je viens de faire ceci (je n'ai pas testé encore, mais ça a l'air d'être correct -comme à chaque fois avant de tester -) :

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
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
Callable<Boolean> callable = new Callable<Boolean>() {
	@Override
	public Boolean call() {
		boolean condition = false;
		if (!condition) {
			/* La tâche ne doit plus continuer de s'exécuter. */
			return false;
		}
		// code
		/* La tâche doit continuer de s'exécuter. */
		return true;
	}
};
FutureTask<Boolean> task = new FutureTask<Boolean>(callable) {
	@Override
	public void run() {
		super.run();
		try {
			if (!get()) {
				cancel(false);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch(ExecutionException e) {
			e.printStackTrace();
		}
	}
};
executor.scheduleWithFixedDelay(task, 10, 10, TimeUnit.SECONDS);

[le y@m's]

Tu ne peux pas tester si future != null ?

Code :

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

1
2
3
if(condition && future != null) {
    future.cancel();
}

[®om]

Tu ne peux pas tester si future != null ?

Code :

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

1
2
3
if(condition && future != null) {
    future.cancel();
}

Non il y a une erreur de non initialisation (et de toute façon quand je suis dans la méthode, il ne faut pas qu'il soit null.