scheduleAtFixedRate a scheduleWithFixedDelay

Jaka jest główna różnica między scheduleAtFixedRatei scheduleWithFixedDelaymetodami usługi ScheduledExecutorService ?

scheduler.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
        System.out.println("scheduleAtFixedRate:    " + new Date());
    }
}, 1, 3L , SECONDS);

scheduler.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
        System.out.println("scheduleWithFixedDelay: " + new Date());
    }
}, 1, 3L , SECONDS);

drukują dokładnie w tym samym czasie, wydaje się, że są wykonywane dokładnie w tym samym czasie.

Spróbuj dodać Thread.sleep(1000);wezwanie w swojej run()metody ... W zasadzie to jest różnica między szeregowania coś na podstawie Kiedy poprzednich realizacji celów i kiedy (logicznie) zaczyna .

Na przykład, przypuśćmy, że planuję uruchamianie alarmu ze stałą częstotliwością raz na godzinę i za każdym razem, gdy się włącza, piję kawę, co zajmuje 10 minut. Załóżmy, że zaczyna się o północy, miałbym:

00:00: Start making coffee
00:10: Finish making coffee
01:00: Start making coffee
01:10: Finish making coffee
02:00: Start making coffee
02:10: Finish making coffee

Gdybym zaplanował ze stałym godzinnym opóźnieniem , miałbym:

00:00: Start making coffee
00:10: Finish making coffee
01:10: Start making coffee
01:20: Finish making coffee
02:20: Start making coffee
02:30: Finish making coffee

Który z nich chcesz, zależy od twojego zadania.

Wizualizuj szeregi czasowe scheduleAtFixedRatemetody wywołania . Kolejne egzekucje rozpoczną się natychmiast, jeśli ostatnia potrwa dłużej niż okres. W przeciwnym razie rozpocznie się po upływie określonego czasu.

Szeregi czasowe scheduleWithFixedDelaymetody wywołania . Kolejna realizacja rozpocznie się po czasie opóźnienia między zakończeniem jednej realizacji a rozpoczęciem następnej, niezależnie od czasu jej wykonania

Hope może ci pomóc

scheduleAtFixedRate()Metoda tworzy nowe zadanie i przekazuje go do realizatora każdy okres, niezależnie od tego, czy poprzednie zadanie zakończone .

Z drugiej strony scheduleWithFixedDelay()metoda tworzy nowe zadanie po zakończeniu poprzedniego zadania .

Jeśli przeczytasz dokument Java, będzie to jaśniejsze

ScheduledFuture scheduleAtFixedRate (polecenie Runnable, long initialDelay, long period, timeUnit) Tworzy i wykonuje okresowe działanie, które jest włączane najpierw po zadanym początkowym opóźnieniu, a następnie w zadanym okresie; to znaczy, że wykonanie rozpocznie się po initialDelay, a następnie initialDelay + okres, a następnie initialDelay + 2 * okres i tak dalej.

ScheduledFuture scheduleWithFixedDelay (Runnable command, long initialDelay, long delay, TimeUnit unit) Tworzy i wykonuje okresowe działanie, które jest włączane najpierw po zadanym początkowym opóźnieniu, a następnie z zadanym opóźnieniem między zakończeniem jednego wykonania a rozpoczęciem następnego.

Jest jeden haczyk w scheduleAtFixedRate, jeśli pierwszy wątek trwa zbyt długo i nie został zakończony w podanym czasie, drugi kolejny wątek nie rozpocznie się po zakończeniu pierwszego zadania i nie rozpocznie się natychmiast, gdy pierwszy wątek zakończy swoje zadanie i uzyska czas trwania upłynął. JVM Zdecyduje, kiedy zostanie wykonane następne zadanie.

Myślę, że pomoże ci to wybrać metodę, ponieważ z tego powodu mam duży problem

Napiszmy prosty program:

import java.util.concurrent.Executors
import java.util.concurrent.TimeUnit

var time = 0L
var start = System.currentTimeMillis()
val executor = Executors.newScheduledThreadPool(1)
executor.scheduleWithFixedDelay({
    if (time >= 12_000L) {
        executor.shutdown()
    } else {
        Thread.sleep(2000L)
        val now = System.currentTimeMillis()
        time += now - start
        System.out.println("Total $time delay ${now - start}\n")
        start = now
    }
}, 0L, 1000L, TimeUnit.MILLISECONDS)

I zobacz wyniki:

| scheduleWithFixedDelay |   scheduleAtFixedRate  |
|:----------------------:|:----------------------:|
| Total 2001 delay 2001  | Total 2003 delay 2003  |
| Total 5002 delay 3001  | Total 4004 delay 2001  |
| Total 8003 delay 3001  | Total 6004 delay 2000  |
| Total 11003 delay 3000 | Total 8004 delay 2000  |
| Total 14003 delay 3000 | Total 10005 delay 2001 |
|          ---           | Total 12005 delay 2000 |

UWAGA czas wykonania jest dłuższy niż czekanie

scheduleWithFixedDelay utrzymuje opóźnienie
scheduleAtFixedRate usuwa opóźnienie

scheduledExecutorService.scheduleAtFixedRate(() -> {
        System.out.println("runnable start"); try { Thread.sleep(5000);  System.out.println("runnable end");} catch
     (InterruptedException e) { // TODO Auto-generated catch block
      e.printStackTrace(); }}, 2, 7, TimeUnit.SECONDS);



     scheduledExecutorService.scheduleWithFixedDelay(() -> {
     System.out.println("runnable start"); try { Thread.sleep(5000); System.out.println("runnable end");} catch
     (InterruptedException e) { // TODO Auto-generated catch block
     e.printStackTrace(); } }, 2, 7, TimeUnit.SECONDS);

Po prostu wykonaj to, a poznasz różnicę. Dziękuję Ci