Javaでタイマーを設定するには？

データベースへの接続を試行し、接続に問題がある場合は例外を発生させるタイマー（例えば2分間）を設定するには？

bravehart_sf
編集された質問 19日 10月 2017 в 11:52
プログラミング
timer java
28日 10月 2010 в 3:59
19 ビュー
ソリューション

この回答の最初の部分は、最初に私が解釈し、何人かの人が参考にしたように、質問されたことを実行する方法です。 その後、質問が明確になったので、回答を拡張して対応しました。

タイマーを設定する。

まず、タイマーを作成する必要があります（ここでは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が発生しますが、実際にはタスクは継続して実行されます*。 しかし、それが起こるまでリソースを消費する可能性があることに注意してください。

Yassin Hajaj
編集した答え 8日 4月 2019 в 9:23
解説 (9)

これを使って

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

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

//Throw your exception
解説 (10)

OK、あなたの問題を理解できたと思います。 フューチャーを使って何かをしようとし、しばらくして何も起こらなければタイムアウトすることができます。

例えば、以下のようになります。

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
}
andrewmu
編集した答え 29日 3月 2012 в 2:20
解説 (3)