ScheduledExecutorService with variable delay

Question

Supongamos que tengo una tarea que está extrayendo elementos de un java.util.concurrent.BlockingQueue y procesándolos.

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

¿Cómo puedo programar/reprogramar la tarea si la frecuencia puede cambiarse dinámicamente?

• La idea es tener un flujo de actualizaciones de datos y propagarlas en el lote a una interfaz gráfica de usuario
• El usuario debe ser capaz de variar la frecuencia de las actualizaciones

Answer 1

No creo que pueda cambiar un retraso de velocidad fija. Creo que debe usar schedule() para realizar una única toma, y ​​programar de nuevo una vez que se haya completado (con un tiempo de espera modificado si es necesario).

Answer 2

No deberías estar usando scheduleAtFixedRate si está intentando procesar varias tareas de cola con un intervalo específico? scheduleWithFixedDelay solo esperará el retraso especificado y luego ejecutará una tarea desde la cola.

En cualquier caso, los métodos schedule* en un ScheduledExecutorService devolverán una referencia ScheduledFuture. Si desea cambiar la tasa, puede cancelar el ScheduledFuture y reprogramar la tarea con una tarifa diferente.

Answer 3

scheduleWithFixedDelay (...) devuelve RunnableScheduledFuture. Para reprogramarlo, puede cancelarlo y reprogramarlo. Para volver a programarlo, es posible que sólo envolver el ingenio RunnableScheduledFuture un nuevo Ejecutable:

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

Answer 4

Uso schedule(Callable<V>, long, TimeUnit) en lugar de scheduleAtFixedRate o scheduleWithFixedDelay. Luego, asegúrese de que su Callable se reprograme a sí mismo o una nueva instancia de Callable en algún momento en el futuro. Por ejemplo:

// 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); 

Este enfoque evita la necesidad de apagar y volver a crear la ScheduledExecutorService.