データベースへの接続を試行し、接続に問題がある場合は例外を発生させるタイマー(例えば2分間)を設定するには?
この回答の最初の部分は、最初に私が解釈し、何人かの人が参考にしたように、質問されたことを実行する方法です。 その後、質問が明確になったので、回答を拡張して対応しました。
タイマーを設定する。
まず、タイマーを作成する必要があります(ここでは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);
// Since Java-8
timer.schedule(() -> /* 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);
// Since Java-8
timer.scheduleAtFixedRate(() -> /* 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がスローされます。
問題点としては、2分を過ぎるとTimeoutExceptionが発生しますが、実際にはタスクは継続して実行されます*。 しかし、それが起こるまでリソースを消費する可能性があることに注意してください。
OK、あなたの問題を理解できたと思います。 フューチャーを使って何かをしようとし、しばらくして何も起こらなければタイムアウトすることができます。
例えば、以下のようになります。
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
}