En attente d'une Minuterie pour finir en Java

Je suis en utilisant java.util.Minuterie pour planifier une tâche périodique. A un moment, je voudrais l'arrêter, et attendez la fin de la.

Minuterie.annuler() permettra d'éviter à l'avenir toute les tâches en cours d'exécution. Comment puis-je m'assurer que toutes les tâches ne sont pas en cours d'exécution au moment (ou attendre pour eux si ils sont?)

Je peux introduire des mécanismes de synchronisation externe, mais je ne vois pas comment ils peuvent couvrir tous les cas. Par exemple, si je synchroniser sur certains moniteurs au sein de la tâche, il me manque encore le cas lorsque la tâche juste commencé à s'exécuter mais ne prenez pas le moniteur.

Qu'est-ce que la pratique recommandée pour l'attente jusqu'à ce que toutes les tâches sont vraiment fait, y compris les tâches en cours d'exécution?

OriginalL'auteur ripper234 | 2009-08-24

  1. 19

    Vous serait mieux à l'aide d'un ScheduledExecutorService au lieu d'une Minuterie pour programmer votre tâche périodique. ScheduledExecutorService fournit un shutdown() méthode qui vous permettra d'exécuter toutes les tâches en attente. Vous pouvez ensuite appeler awaitTermination() pour attendre l'arrêt() pour terminer.

    +1. Ou, si vous devez utiliser un Timer pour une raison quelconque, vous pouvez utiliser une Condition (java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/locks/...) pour synchroniser les deux fils sur un événement (tel que l'achèvement de la tâche planifiée).
    Ouais, point 68 Effective Java (2e éd) recommande ScheduledThreadPoolExecutor plus flexible de remplacement pour la Minuterie. +1 pour la mention de cela, que les pratiques recommandées ont été demandé.
    Ouais, je devrais vraiment lire ce livre.
    Ou utiliser un CountdownLatch etc. stackoverflow.com/questions/289434/...

    OriginalL'auteur Mark

  2. 0

    Quelque chose comme ci-dessous peut aider à vos besoins-

    import java.util.Timer;
import java.util.TimerTask;
public class TimerGracefulShutdown {
public static void main(String[] args) throws InterruptedException {
//This is a synchronization helper class
SyncHelper syncHelper = new SyncHelper();
TimerManager myTimerManager = new TimerManager(syncHelper);
//Try stopping timer after 5 seconds (it wont stop until the 30 seconds sleep of timertask does not finish)
Thread.currentThread().sleep(5000);
System.out.println("Going to stop my timer now");
myTimerManager.stopTimer();
System.out.println("Cancelled timer");
}
}
class TimerManager {
SyncHelper syncHelper;
Timer timer;
public TimerManager(SyncHelper syncHelper) {
this.syncHelper = syncHelper;
startTimer();
}
private void startTimer() {
timer = new Timer(true);
TimerTask myTask = new MyTimerTask(syncHelper);
timer.scheduleAtFixedRate(myTask, 0, 100000);
}
public void stopTimer() {
try {
syncHelper.testAndSetOrReset("acquire");
} catch(Exception e) {
e.printStackTrace();
}
//Shutdown the timer here since you know that your timertask is not executing right now.
timer.cancel();
try {
syncHelper.testAndSetOrReset("release");
} catch (Exception e) {
e.printStackTrace();
}
}
}
class MyTimerTask extends TimerTask {
private SyncHelper syncHelper;
public MyTimerTask(SyncHelper syncHelper) {
this.syncHelper = syncHelper;
}
public void run() {
try {
syncHelper.testAndSetOrReset("acquire");
} catch (Exception e1) {
e1.printStackTrace();
}
System.out.println("Over here");
try {
Thread.currentThread().sleep(30000);
} catch(Exception e) {
}
System.out.println("Done sleeping");
//Finally release the helper.
try {
syncHelper.testAndSetOrReset("release");
} catch (Exception e) {
e.printStackTrace();
}
}
}
class SyncHelper {
private int index = 0;
public synchronized void testAndSetOrReset(String command) throws Exception {
if("acquire".equals(command)) { 
if(index == 1) {
wait();
}
index++;
} else if("release".equals(command)) {
index--;
notifyAll();
}
}
}
    Vous devez utiliser Thread.sleep(...) au lieu de Thread.currentThread().sleep(...) parce que c'est une méthode statique; votre code pourraient vous inciter à faire someOtherThread.sleep(...) qui ne dort pas someOtherThread.

    OriginalL'auteur Keshav