Как установить таймер, скажем, на 2 минуты, чтобы попытаться подключиться к базе данных, а затем выдать исключение, если возникнут какие-либо проблемы с подключением?
Переведено автоматически
Ответ 1
Итак, первая часть ответа заключается в том, как выполнить то, о чем просит субъект, поскольку именно так я изначально это интерпретировал, и несколько человек, похоже, сочли полезным. С тех пор вопрос был прояснен, и я расширил ответ, чтобы решить этот вопрос.
Установка таймера
Сначала вам нужно создать таймер (я использую java.util версию здесь):
import java.util.Timer;
..
Timertimer=newTimer();
Чтобы запустить задачу один раз, вы должны выполнить:
timer.schedule(newTimerTask() { @Override publicvoidrun() { // Your database code here } }, 2*60*1000); // Since Java-8 timer.schedule(() -> /* your database code here */, 2*60*1000);
Чтобы задача повторялась по истечении времени, которое вы бы выполнили:
timer.scheduleAtFixedRate(newTimerTask() { @Override publicvoidrun() { // 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);
Создание тайм-аута задачи
Чтобы конкретно выполнить то, что задано в уточненном вопросе, то есть попытаться выполнить задачу в течение заданного периода времени, вы могли бы сделать следующее:
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 по истечении двух минут, задача фактически продолжит выполняться, хотя предположительно время ожидания базы данных или сетевого подключения в конечном итоге истечет и вызовет исключение в потоке. Но имейте в виду, что это может потреблять ресурсы, пока это не произойдет.
while (elapsedTime < 2*60*1000) { //perform db poll/check elapsedTime = (newDate()).getTime() - startTime; }
//Throw your exception
Ответ 3
Хорошо, думаю, теперь я понимаю вашу проблему. Вы можете использовать Future, чтобы попытаться что-то сделать, а затем немного подождать, если ничего не произошло.
Например.:
FutureTask<Void> task = newFutureTask<Void>(newCallable<Void>() { @Override public Void call()throws Exception { // Do DB stuff returnnull; } });