Главная / Concurrency / От задач Timer к запланированным исполнителям
Concurrency Средний

От задач Timer к запланированным исполнителям

Замените Timer и TimerTask на ScheduledExecutorService для надёжной запланированной работы.

Concurrency
Сравнение кода
✕ 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);
Заметили проблему в этом коде? Сообщите нам.
Почему современный подход лучше
🧵

Лучшая изоляция

Настраиваемый пул потоков предотвращает совместное использование одного хрупкого воркера несвязанными задачами.

🛡

Надёжное выполнение

Сбой одной задачи не завершает работу самого планировщика.

🎛

Управляемый жизненный цикл

Future, отмена, задержки и завершение работы используют стандартные API executor'ов.

Старый подход
Timer и TimerTask
Современный подход
ScheduledExecutorService
Начиная с JDK
5
Сложность
Средний
Поддержка JDK
От задач Timer к запланированным исполнителям
Доступно

Широко доступно начиная с JDK 5 (сент. 2004)

Как это работает

Timer выполняет все задачи в одном потоке, поэтому одна долго выполняющаяся задача задерживает остальные, а необработанное исключение завершает поток таймера. ScheduledExecutorService использует framework executor'ов, поддерживает несколько воркеров, возвращает дескрипторы ScheduledFuture и предоставляет явное управление жизненным циклом. Владеющий компонент должен останавливать планировщик, когда он больше не нужен.

Связанная документация
ScheduledExecutorService ↗ Executors ↗
Доказательство
Посмотреть исходник доказательства ↗
Похожие шаблоны
Concurrency Начинающий

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
Наведите, чтобы увидеть современный ➜
JDK 19+ →
Concurrency Начинающий

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)
);
Наведите, чтобы увидеть современный ➜
JDK 19+ →
Concurrency Продвинутый

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());
}
Наведите, чтобы увидеть современный ➜
JDK 25+ →