Come impostare un timer in Java?

Come impostare un timer, ad esempio per 2 minuti, per provare a connettersi a un database quindi generare un’eccezione se c’è qualche problema nella connessione?

Quindi la prima parte della risposta è come fare ciò che il sobject chiede in quanto è stato il modo in cui l’ho inizialmente interpretato e alcune persone sembrano trovare utili. La domanda è stata chiarita da allora e ho esteso la risposta per risolverlo.

Impostazione di un timer

Per prima cosa devi creare un timer (sto usando la versione java.util qui):

 import java.util.Timer; 

..

 Timer timer = new Timer(); 

Per eseguire l’attività una volta fatto:

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

Per ripetere l’attività dopo la durata, procedere come segue:

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

Esecuzione di un timeout dell’attività

Per fare specificamente ciò che chiede la domanda chiarita, ovvero tentare di eseguire un’attività per un determinato periodo di tempo, è ansible fare quanto segue:

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

Questo verrà eseguito normalmente con eccezioni se l’attività viene completata entro 2 minuti. Se viene eseguito più a lungo, verrà lanciata la TimeoutException.

Un problema è che, sebbene dopo i due minuti si ottenga un valore di TimeoutException, l’attività continuerà effettivamente a funzionare , anche se presumibilmente un database o una connessione di rete terminerà il timeout e genererà un’eccezione nel thread. Ma sappi che potrebbe consumare risorse finché ciò non accadrà.

Usa questo

 long startTime = System.currentTimeMillis(); long elapsedTime = 0L. while (elapsedTime < 2*60*1000) { //perform db poll/check elapsedTime = (new Date()).getTime() - startTime; } //Throw your exception 

Ok, penso di aver capito il tuo problema ora. Puoi usare un futuro per provare a fare qualcosa e poi sospendere dopo un po ‘se non è successo nulla.

Per esempio:

 FutureTask task = new FutureTask(new Callable() { @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 } 

Come fermare il timer? Fermati e riproduci di nuovo quando fai qualcosa in questo codice

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

Quando uso il timer.cancel();

si fermerà ma se chiudi il modulo e lo apri di nuovo viene lanciata l’eccezione

 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) 
  new java.util.Timer().schedule(new TimerTask(){ @Override public void run() { System.out.println("Executed..."); //your code here //1000*5=5000 mlsec. ie 5 seconds. u can change accordngly } },1000*5,1000*5);