可変遅延付きScheduledExecutorService

Question

java.util.concurrent.BlockingQueueから要素を引き出して処理するタスクがあるとします。

public void scheduleTask(int delay, TimeUnit timeUnit) 
{ 
    scheduledExecutorService.scheduleWithFixedDelay(new Task(queue), 0, delay, timeUnit); 
} 

頻度を動的に変更できる場合は、どのようにタスクをスケジュール/再スケジュールできますか？

• アイデアは、ユーザーがアップデート

Answer 1

固定レート遅延を変更することはできません。私はあなたがワンショットを実行するためにschedule()を使用する必要があると思うし、もう一度完了した（必要に応じて変更されたタイムアウトで）スケジュールを立てます。

Answer 2

の周波数を変化させることができるはずのデータ更新の流れを取り、GUI

に一括でそれらを伝播することであるあなたが使用してはいけません特定の間隔で複数のキュータスクを処理しようとしている場合はscheduleAtFixedRate？ scheduleWithFixedDelayは、指定された遅延を待ってから、キューから1つのタスクを実行します。いずれの場合でも、ScheduledExecutorServiceのschedule*の方法は、ScheduledFutureの参照を返す。レートを変更する場合は、ScheduledFutureをキャンセルして、異なるレートでタスクを再スケジュールすることができます。

Answer 3

scheduleWithFixedDelay（...）は、RunnableScheduledFutureを返します。再スケジュールするには、キャンセルして再スケジュールするだけです。むしろscheduleAtFixedRateまたはscheduleWithFixedDelayより

new Runnable() { 
    public void run() { 
     ((RunnableScheduledFuture)future).run(); 
    } 
}; 

Answer 4

使用schedule(Callable<V>, long, TimeUnit)：それを再スケジュールするには、あなただけのRunnableScheduledFutureウィット新しいRunnableをを包むことがあります。次に、Callable が今後予定されているか、または新しいCallableインスタンスが将来予定されていることを確認してください。たとえば：

// Create Callable instance to schedule. 
Callable<Void> c = new Callable<Void>() { 
    public Void call() { 
    try { 
    // Do work. 
    } finally { 
    // Reschedule in new Callable, typically with a delay based on the result 
    // of this Callable. In this example the Callable is stateless so we 
    // simply reschedule passing a reference to this. 
    service.schedule(this, 5000L, TimeUnit.MILLISECONDS); 
    } 
    return null; 
    } 
} 

service.schedule(c); 

このアプローチはシャットダウンしScheduledExecutorServiceを再作成する必要がありません。