Action toutes les x secondes annulable : comment faire?

Version imprimable

Executor : Action toutes les x secondes annulable : comment faire?

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:

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?

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 :aie: -) :

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
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);

11/07/2007, 15h31
le y@m's
Tu ne peux pas tester si future != null ?
Code:

1 2 3 if(condition && future != null) { future.cancel(); }
11/07/2007, 15h36
®om
Citation:
Envoyé par le y@m's

Tu ne peux pas tester si future != null ?

Code:

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.