Класс ScheduledThreadPoolExecutor

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

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

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

Хотя этот класс наследуется от 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.
 }