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

Вы не должны использовать scheduleAtFixedRate, если вы пытаетесь обработать несколько задач очереди с определенным интервалом? scheduleWithFixedDelay будет ждать только указанной задержки, а затем выполнить одно задание из очереди.

В любом случае методы schedule* в ScheduledExecutorService вернут ссылку ScheduledFuture. Если вы хотите изменить скорость, вы можете отменить ScheduledFuture и перенести задачу с другой скоростью.

Answer 3

scheduleWithFixedDelay (...) возвращает RunnableScheduledFuture. Чтобы перенести его, вы можете просто отменить и перенести его. Для того, чтобы перенести его, вы можете просто оберните RunnableScheduledFuture остроумие новый Runnable:

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

Answer 4

Использование schedule(Callable<V>, long, TimeUnit) вместо scheduleAtFixedRate или scheduleWithFixedDelay. Затем убедитесь, что ваш 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.