Интерфейс ScheduledExecutorService

Все суперинтерфейсы:: AutoCloseable, Executor, ExecutorService

Все известные реализующие классы:: ScheduledThreadPoolExecutor

public interface ScheduledExecutorService extends ExecutorService

Объект ExecutorService, который может планировать выполнение команд с заданной задержкой или выполнять их периодически.

Методы schedule создают задачи с различными задержками и возвращают объект задачи, который можно использовать для отмены или проверки выполнения. Методы scheduleAtFixedRate и scheduleWithFixedDelay создают и выполняют задачи, которые выполняются периодически до отмены.

Команды, отправленные с помощью методов Executor.execute(Runnable) и ExecutorService submit, планируются с запрошенной задержкой в ноль. Ноль и отрицательные задержки (но не периоды) также разрешены в методах schedule и обрабатываются как запросы на немедленное выполнение.

Все методы schedule принимают относительные задержки и периоды в качестве аргументов, а не абсолютные временные моменты или даты. Преобразование абсолютного времени, представленного как Date, в необходимый вид — простая задача. Например, чтобы запланировать выполнение в определённом будущем date, можно использовать: schedule(task, date.getTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS). Однако следует учитывать, что истечение относительной задержки может не совпадать с текущим Date, когда задача становится активной, из-за протоколов синхронизации времени сети, дрейфа часов или других факторов.

Класс Executors предоставляет удобные фабричные методы для реализаций ScheduledExecutorService, предоставляемых в этом пакете.

Пример использования

Вот класс с методом, который настраивает ScheduledExecutorService для воспроизведения сигнала каждые десять секунд в течение часа:

 
 import static java.util.concurrent.TimeUnit.*;
 class BeeperControl {
   private final ScheduledExecutorService scheduler =
     Executors.newScheduledThreadPool(1);

   public void beepForAnHour() {
     Runnable beeper = () -> System.out.println("beep");
     ScheduledFuture<?> beeperHandle =
       scheduler.scheduleAtFixedRate(beeper, 10, 10, SECONDS);
     Runnable canceller = () -> beeperHandle.cancel(false);
     scheduler.schedule(canceller, 1, HOURS);
   }
 }

С:: 1.5

Краткое описание методов

Модификатор и тип	Метод	Описание
`ScheduledFuture<?>`	`schedule(Runnable command, long delay, TimeUnit unit)`	Отправляет одноразовую задачу, которая становится активной после заданной задержки.
`<V> ScheduledFuture<V>`	`schedule(Callable<V> callable, long delay, TimeUnit unit)`	Отправляет возвращающую значение одноразовую задачу, которая становится активной после заданной задержки.
`ScheduledFuture<?>`	`scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)`	Отправляет периодическое действие, которое становится активным сначала после заданной начальной задержки, а затем с заданным периодом; то есть, выполнение начнется после `initialDelay`, затем `initialDelay + period`, затем `initialDelay + 2 * period` и так далее.
`ScheduledFuture<?>`	`scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)`	Отправляет периодическое действие, которое становится активным сначала после заданной начальной задержки, а затем с заданным интервалом между завершением одного выполнения и началом следующего.

Методы, объявленные в интерфейсе java.util.concurrent.Executor

execute

Методы, объявленные в интерфейсе java.util.concurrent.ExecutorService

awaitTermination, close, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Подробное описание методов

schedule

ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)

Отправляет одноразовую задачу, которая становится активной после заданной задержки.

Параметры:: command - задача для выполнения; delay - время задержки выполнения; unit - единица измерения времени для параметра задержки
Возвращает:: ScheduledFuture, представляющий ожидаемое завершение задачи, и метод get() которого вернёт null при завершении
Исключения:: RejectedExecutionException - если задача не может быть запланирована для выполнения; NullPointerException - если команда или единица измерения равны null

schedule

<V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit)

Отправляет возвращающую значение одноразовую задачу, которая становится активной после заданной задержки.

Параметры типа:: V - тип результата вызова
Параметры:: callable - функция для выполнения; delay - время задержки выполнения; unit - единица измерения времени для параметра задержки
Возвращает:: ScheduledFuture, который можно использовать для извлечения результата или отмены
Исключения:: RejectedExecutionException - если задача не может быть запланирована для выполнения; NullPointerException - если callable или единица измерения равны null

scheduleAtFixedRate

ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)

Отправляет периодическое действие, которое становится активным сначала после заданной начальной задержки, а затем с заданным периодом; то есть, выполнение начнется после initialDelay, затем initialDelay + period, затем initialDelay + 2 * period и так далее.

Последовательность выполнений задачи продолжается неопределённо, пока не произойдёт одно из следующих исключительных завершений:

Задача явным образом отменяется с помощью возвращённого объекта future.
Исполнитель завершается, что также приводит к отмене задачи.
Выполнение задачи вызывает исключение. В этом случае вызов get на возвращённом объекте future вызовет ExecutionException, содержащий исключение в качестве причины.

Последующие выполнения подавляются. Последующие вызовы isDone() на возвращённом объекте future вернут true.

Если любое выполнение этой задачи занимает больше времени, чем её период, то последующие выполнения могут начаться с опозданием, но не будут выполняться одновременно.

Параметры:: command - задача для выполнения; initialDelay - время задержки первого выполнения; period - период между последовательными выполнениями; unit - единица измерения времени для параметров initialDelay и period
Возвращает:: ScheduledFuture, представляющий ожидаемое завершение серии повторяющихся задач. Метод get() объекта future никогда не вернёт значение нормально и вызовет исключение при отмене задачи или аномальном завершении выполнения задачи.
Исключения:: RejectedExecutionException - если задача не может быть запланирована для выполнения; NullPointerException - если команда или единица измерения равны null; IllegalArgumentException - если период меньше или равен нулю

scheduleWithFixedDelay

ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)

Отправляет периодическое действие, которое становится активным сначала после заданной начальной задержки, а затем с заданным интервалом между завершением одного выполнения и началом следующего.

Задача явным образом отменяется с помощью возвращённого объекта future.
Исполнитель завершается, что также приводит к отмене задачи.
Выполнение задачи вызывает исключение. В этом случае вызов get на возвращённом объекте future вызовет ExecutionException, содержащий исключение в качестве причины.

Последующие выполнения подавляются. Последующие вызовы isDone() на возвращённом объекте future вернут true.

Параметры:: command - задача для выполнения; initialDelay - время задержки первого выполнения; delay - интервал между завершением одного выполнения и началом следующего; unit - единица измерения времени для параметров initialDelay и delay
Возвращает:: ScheduledFuture, представляющий ожидаемое завершение серии повторяющихся задач. Метод get() объекта future никогда не вернёт значение нормально и вызовет исключение при отмене задачи или аномальном завершении выполнения задачи.
Исключения:: RejectedExecutionException - если задача не может быть запланирована для выполнения; NullPointerException - если команда или единица измерения равны null; IllegalArgumentException - если интервал меньше или равен нулю

© 1993, 2025, Oracle and/or its affiliates. All rights reserved.
Documentation extracted from Debian's OpenJDK Development Kit package.
Licensed under the GNU General Public License, version 2, with the Classpath Exception.
Various third party code in OpenJDK is licensed under different licenses (see Debian package).
Java and OpenJDK are trademarks or registered trademarks of Oracle and/or its affiliates.
https://download.java.net/java/early_access/jdk24/docs/api/java.base/java/util/concurrent/ScheduledExecutorService.html