Класс ScheduledThreadPoolExecutor

public class ScheduledThreadPoolExecutor
extends ThreadPoolExecutor
implements ScheduledExecutorService

A ThreadPoolExecutor который дополнительно может планировать выполнение команд после заданной задержки или периодическое выполнение. Этот класс предпочтительнее Timer когда требуется несколько рабочих потоков или необходима дополнительная гибкость или возможности ThreadPoolExecutor (который этот класс расширяет).

Задачи с задержкой выполняются не раньше, чем они разрешены, но без каких-либо гарантий реального времени о том, когда, после разрешения, они начнутся. Задачи, запланированные на одинаковое время выполнения, разрешаются в порядке очереди FIFO (первый пришёл, первый обслужен) в порядке их поступления.

Если задача, отправленная на выполнение, отменяется до ее запуска, выполнение подавляется. По умолчанию такая отменённая задача не удаляется автоматически из очереди задач до истечения её задержки. Хотя это позволяет проводить дальнейший анализ и мониторинг, это может также привести к неограниченному хранению отменённых задач. Чтобы избежать этого, используйте setRemoveOnCancelPolicy(boolean), чтобы задачи удалялись немедленно из очереди задач при отмене.

Последовательные исполнения периодической задачи, запланированной с помощью scheduleAtFixedRate или scheduleWithFixedDelay, не перекрываются. Хотя разные исполнения могут выполняться в разных потоках, результаты предыдущих исполнений happen-before результатов последующих.

Хотя этот класс унаследован от ThreadPoolExecutor, некоторые унаследованные методы настройки не полезны для него. В частности, поскольку он действует как пул фиксированного размера, использующий corePoolSize потоков и неограниченную очередь, корректировки maximumPoolSize не оказывают полезного эффекта. Кроме того, почти никогда не стоит устанавливать corePoolSize в ноль или использовать allowCoreThreadTimeOut, потому что это может оставить пул без потоков для обработки задач, когда они станут готовыми к выполнению.

Как и ThreadPoolExecutor, если не указано иное, этот класс использует Executors.defaultThreadFactory() в качестве фабрики потоков по умолчанию и ThreadPoolExecutor.AbortPolicy в качестве обработчика отменённых задач по умолчанию.

Примечания по расширению: Этот класс переопределяет методы execute и submit для генерации внутренних объектов ScheduledFuture для управления задержками и планированием каждой задачи. Для сохранения функциональности любые дальнейшие переопределения этих методов в подклассах должны вызывать версии суперкласса, что фактически отключает дополнительную настройку задач. Однако этот класс предоставляет альтернативный защищённый метод расширения decorateTask (по одной версии для Runnable и Callable ), который можно использовать для настройки конкретных типов задач, используемых для выполнения команд, введённых через execute, submit, schedule, scheduleAtFixedRate, и scheduleWithFixedDelay. По умолчанию ScheduledThreadPoolExecutor использует тип задачи, расширяющий FutureTask. Однако это можно изменить или заменить, используя подклассы в форме:

public class CustomScheduledExecutor extends ScheduledThreadPoolExecutor {

   static class CustomTask<V> implements RunnableScheduledFuture<V> { ... }

   protected <V> RunnableScheduledFuture<V> decorateTask(
                Runnable r, RunnableScheduledFuture<V> task) {
       return new CustomTask<V>(r, task);
   }

   protected <V> RunnableScheduledFuture<V> decorateTask(
                Callable<V> c, RunnableScheduledFuture<V> task) {
       return new CustomTask<V>(c, task);
   }
   // ... add constructors, etc.
 }