Comment définir une minuterie en Java ?

Question

Comment définir une minuterie, par exemple pendant 2 minutes, pour essayer de se connecter à une base de données et lancer une exception en cas de problème de connexion ?

Answer 1

La première partie de la réponse porte sur la façon de faire ce que le sujet demande, car c'est ainsi que je l'ai initialement interprétée et que quelques personnes ont semblé la trouver utile. La question a été clarifiée depuis et j'ai étendu la réponse pour y répondre.

Réglage d'une minuterie

Tout d'abord, vous devez créer un Timer (j'utilise la fonction java.util version ici) :

import java.util.Timer;

..

Timer timer = new Timer();

Pour exécuter la tâche une fois, vous devez faire ce qui suit

timer.schedule(new TimerTask() {
  @Override
  public void run() {
    // Your database code here
  }
}, 2*60*1000);
// Since Java-8
timer.schedule(() -> /* your database code here */, 2*60*1000);

Pour que la tâche se répète après la durée que vous feriez :

timer.scheduleAtFixedRate(new TimerTask() {
  @Override
  public void run() {
    // Your database code here
  }
}, 2*60*1000, 2*60*1000);

// Since Java-8
timer.scheduleAtFixedRate(() -> /* your database code here */, 2*60*1000, 2*60*1000);

Faire en sorte que le délai d'une tâche soit dépassé

Pour faire spécifiquement ce que la question clarifiée demande, c'est-à-dire tenter d'effectuer une tâche pendant une période donnée, vous pourriez faire ce qui suit :

ExecutorService service = Executors.newSingleThreadExecutor();

try {
    Runnable r = new Runnable() {
        @Override
        public void run() {
            // Database task
        }
    };

    Future<?> f = service.submit(r);

    f.get(2, TimeUnit.MINUTES);     // attempt the task for two minutes
}
catch (final InterruptedException e) {
    // The thread was interrupted during sleep, wait or join
}
catch (final TimeoutException e) {
    // Took too long!
}
catch (final ExecutionException e) {
    // An exception from within the Runnable task
}
finally {
    service.shutdown();
}

Cela s'exécutera normalement avec des exceptions si la tâche se termine dans les 2 minutes. Si elle s'exécute plus longtemps que cela, l'exception TimeoutException sera lancée.

Un problème est que même si vous obtenez une TimeoutException après les deux minutes, la tâche continuera réellement à s'exécuter Il est probable qu'une connexion à une base de données ou à un réseau finira par s'interrompre et déclencher une exception dans le fil de discussion. Mais sachez que cela peut consommer des ressources jusqu'à ce que cela se produise.

Answer 2

Utilisez cette

long startTime = System.currentTimeMillis();
long elapsedTime = 0L.

while (elapsedTime < 2*60*1000) {
    //perform db poll/check
    elapsedTime = (new Date()).getTime() - startTime;
}

//Throw your exception

Answer 3

Ok, je pense que je comprends votre problème maintenant. Vous pouvez utiliser un Future pour essayer de faire quelque chose, puis attendre un peu si rien ne s'est passé.

Par exemple :

FutureTask<Void> task = new FutureTask<Void>(new Callable<Void>() {
  @Override
  public Void call() throws Exception {
    // Do DB stuff
    return null;
  }
});

Executor executor = Executors.newSingleThreadScheduledExecutor();
executor.execute(task);

try {
  task.get(5, TimeUnit.SECONDS);
}
catch(Exception ex) {
  // Handle your exception
}

Answer 4

Comment arrêter le minuteur ? Arrêtez et jouez à nouveau lorsque vous faites quelque chose dans ce code.

timer.scheduleAtFixedRate(new TimerTask() {
  @Override
  public void run() {
    // Your database code here
  }
}, 2*60*1000, 2*60*1000);

Lorsque j'utilise le timer.cancel();

il s'arrêtera mais si on ferme le formulaire et qu'on l'ouvre à nouveau, le problème sera résolu.

Exception
Exception in thread "AWT-EventQueue-0" java.lang.IllegalStateException: Timer already cancelled.
    at java.util.Timer.sched(Timer.java:354)
    at java.util.Timer.scheduleAtFixedRate(Timer.java:296)
    at View.Electronic_Meeting.this_componentShown(Electronic_Meeting.java:295)
    at View.Electronic_Meeting.access$000(Electronic_Meeting.java:36)
    at View.Electronic_Meeting$1.componentShown(Electronic_Meeting.java:85)
    at java.awt.AWTEventMulticaster.componentShown(AWTEventMulticaster.java:162)
    at java.awt.Component.processComponentEvent(Component.java:6095)
    at java.awt.Component.processEvent(Component.java:6043)
    at java.awt.Container.processEvent(Container.java:2041)
    at java.awt.Component.dispatchEventImpl(Component.java:4630)
    at java.awt.Container.dispatchEventImpl(Container.java:2099)
    at java.awt.Component.dispatchEvent(Component.java:4460)
    at java.awt.EventQueue.dispatchEvent(EventQueue.java:599)
    at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:269)
    at java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:184)
    at java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:174)
    at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:169)
    at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:161)
    at java.awt.EventDispatchThread.run(EventDispatchThread.java:122)

Answer 5

    new java.util.Timer().schedule(new TimerTask(){
        @Override
        public void run() {
            System.out.println("Executed...");
           //your code here 
           //1000*5=5000 mlsec. i.e. 5 seconds. u can change accordngly 
        }
    },1000*5,1000*5);