Strona główna / Concurrency / Z zadań Timer do zaplanowanych executorów
Concurrency Średniozaawansowany

Z zadań Timer do zaplanowanych executorów

Zastąp Timer i TimerTask za pomocą ScheduledExecutorService dla solidnej pracy zaplanowanej.

Concurrency
Porównanie kodu
✕ Timer and TimerTask 
Timer timer = new Timer("refresh-timer");
timer.scheduleAtFixedRate(new TimerTask() {
    @Override
    public void run() {
        refresh();
    }
}, 0, 60_000);
✓ ScheduledExecutorService 
ScheduledExecutorService scheduler =
        Executors.newScheduledThreadPool(2);

scheduler.scheduleAtFixedRate(
        this::refresh, 0, 1, TimeUnit.MINUTES);
Widzisz problem z tym kodem? Daj nam znać.
Dlaczego nowoczesne podejście wygrywa
🧵

Lepsza izolacja

Konfigurowalna pula wątków zapobiega dzieleniu jednego kruchego workera przez niepowiązane harmonogramy.

🛡

Solidne wykonanie

Niepowodzenie jednego zadania nie kończy działania samego schedulera.

🎛

Kontrolowany cykl życia

Future, anulowanie, opóźnienia i zamykanie korzystają ze standardowych API executorów.

Stare podejście
Timer i TimerTask
Nowoczesne podejście
ScheduledExecutorService
Od JDK
5
Poziom trudności
Średniozaawansowany
Wsparcie JDK
Z zadań Timer do zaplanowanych executorów
Dostępne

Szeroko dostępne od JDK 5 (wrz. 2004)

Jak to działa

Timer wykonuje każde zadanie na jednym wątku, więc długo działające zadanie opóźnia inne, a nieobsłużony wyjątek kończy działanie wątku timera. ScheduledExecutorService korzysta z frameworka executorów, obsługuje wielu workerów, zwraca uchwyty ScheduledFuture i zapewnia jawne zarządzanie cyklem życia. Komponent właścicielski musi zamknąć scheduler, gdy nie jest już potrzebny.

Powiązana dokumentacja
ScheduledExecutorService ↗ Executors ↗
Dowód
Zobacz źródło dowodu ↗
Powiązane wzorce
Concurrency Początkujący

ExecutorService auto-close

Java 8
ExecutorService exec =
    Executors.newCachedThreadPool();
try {
    exec.submit(task);
} finally {
    exec.shutdown();
    exec.awaitTermination(
        1, TimeUnit.MINUTES);
}
Java 19+
try (var exec =
        Executors.newCachedThreadPool()) {
    exec.submit(task);
}
// auto shutdown + await on close
Najedź, aby zobaczyć nową wersję ➜
JDK 19+ →
Concurrency Początkujący

Thread.sleep with Duration

Java 8
// What unit is 5000? ms? us?
Thread.sleep(5000);

// 2.5 seconds: math required
Thread.sleep(2500);
Java 19+
Thread.sleep(
    Duration.ofSeconds(5)
);
Thread.sleep(
    Duration.ofMillis(2500)
);
Najedź, aby zobaczyć nową wersję ➜
JDK 19+ →
Concurrency Zaawansowany

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
Najedź, aby zobaczyć nową wersję ➜
JDK 25+ →