5 ответов:
Итак, первая часть ответа заключается в том, как сделать то, о чем спрашивает субъект, поскольку именно так я первоначально интерпретировал это, и несколько человек, похоже, сочли это полезным. С тех пор вопрос был прояснен, и я расширил ответ, чтобы решить эту проблему.
Установка таймера
Сначала вам нужно создать таймер (я использую версию
java.util
здесь):import java.util.Timer;
..
Timer timer = new Timer();
Чтобы запустить задачу, как только вы сделаете:
timer.schedule(new TimerTask() { @Override public void run() { // Your database code here } }, 2*60*1000);
Чтобы задание повторилось после того, как вы сделал бы:
timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { // Your database code here } }, 2*60*1000, 2*60*1000);
Создание таймаута задачи
Чтобы конкретно сделать то, что требует проясненный вопрос, то есть попытаться выполнить задачу в течение заданного периода времени, вы можете сделать следующее:
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(); }
Это будет выполняться нормально с исключениями, если задача завершится в течение 2 минут. Если он работает дольше, чем это, TimeoutException будет брошен.
Одна из проблем заключается в том, что, хотя вы получите TimeoutException через две минуты, задача будет на самом деле продолжайте выполнять, хотя предположительно база данных или сетевое соединение в конечном итоге будет тайм-аут и выдаст исключение в потоке. Но имейте в виду, что он может потреблять ресурсы, пока это не произойдет.
Используйте это
long startTime = System.currentTimeMillis(); long elapsedTime = 0L. while (elapsedTime < 2*60*1000) { //perform db poll/check elapsedTime = (new Date()).getTime() - startTime; } //Throw your exception
Хорошо, теперь я, кажется, понимаю вашу проблему. Вы можете использовать будущее, чтобы попытаться что-то сделать, а затем тайм-аут через некоторое время, если ничего не произошло.
Например:
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 }
Как остановить таймер? Остановитесь и играйте снова, когда что-то делаете в этом коде
timer.scheduleAtFixedRate(new TimerTask() { @Override public void run() { // Your database code here } }, 2*60*1000, 2*60*1000);
Когда я использую
timer.cancel();
Он остановится, но если закрыть форму и открыть ее снова, то возникнет исключение
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. i.e. 5 seconds. u can change accordngly } },1000*5,1000*5);
Comments