ScheduledEexecutorService ze zmiennym opóźnieniem

Question

Załóżmy, że mam zadanie, które pobiera elementy z java.util.concurrent.BlockingQueue i przetwarza je.

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

Jak mogę zaplanować/zmienić harmonogram zadania, jeśli częstotliwość może być zmieniana dynamicznie?

• Chodzi o to, aby wziąć strumień aktualizacji danych i propagować je w partii do GUI
• Użytkownik powinien być w stanie zmieniać częstotliwość aktualizacji

Answer 1

Nie sądzę, aby można było zmienić oprocentowanie na stałą stopę procentową. Myślę, że musisz użyć schedule(), aby wykonać jednorazowe zdjęcie, i zaplanować ponownie, gdy zostanie ukończone (ze zmodyfikowanym czasem oczekiwania, jeśli jest to wymagane).

Answer 2

nie należy używać scheduleAtFixedRate, jeśli próbujesz przetworzyć kilka zadań kolejkowania z określoną częstotliwością? scheduleWithFixedDelay będzie tylko czekać na określone opóźnienie, a następnie wykonać jedno zadanie z kolejki.

W obu przypadkach metody schedule* w obiekcie ScheduledExecutorService zwrócą numer referencyjny ScheduledFuture. Jeśli chcesz zmienić stawkę, możesz anulować ScheduledFuture i zmienić harmonogram zadania z inną stawką.

Answer 3

scheduleWithFixedDelay (...) zwraca RunnableScheduledFuture. Aby zmienić harmonogram, możesz po prostu anulować i zmienić harmonogram. Przełożyć go, może po prostu owinąć dowcip RunnableScheduledFuture nowy Runnable:

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

Answer 4

Zastosowanie schedule(Callable<V>, long, TimeUnit) zamiast scheduleAtFixedRate lub scheduleWithFixedDelay. Następnie upewnij się, że Twój Callable zmieni się sam lub pojawi się nowa instancja z opcją wywołania w pewnym momencie w przyszłości. Na przykład:

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

Takie podejście pozwala na uniknięcie konieczności wyłączania i ponownie ScheduledExecutorService.