java.util.concurrent

Класс ScheduledThreadPoolExecutor

java.lang. Объект

java.util.concurrent.AbstractExecutorService

java.util.concurrent. ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

Все Реализованные Интерфейсы:

Исполнитель, Эксекуторсервайс, ScheduledExecutorService

public class ScheduledThreadPoolExecutor
extends ThreadPoolExecutor
implements ScheduledExecutorService

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

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

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

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

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

Примечания расширения: Этот класс переопределяет execute и submit методы, чтобы генерировать внутренний ScheduledFuture объекты управлять задержками на задачу и планированием. Чтобы сохранить функциональность, дальнейшие переопределения этих методов в подклассах должны вызвать версии суперкласса, который эффективно отключает дополнительную настройку задачи. Однако, этот класс обеспечивает альтернативу защищенный метод расширения decorateTask (одна версия каждый для Runnable и Callable) это может использоваться, чтобы настроить конкретные типы задачи, используемые, чтобы выполнить команды, вводимые через execute, submit, schedule, scheduleAtFixedRate, и scheduleWithFixedDelay. По умолчанию, a 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.
 }

С тех пор:

1.5

Вложенная Сводка Класса

Вложенные классы/интерфейсы java.util.concurrent унаследованный от класса. ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Сводка конструктора

Конструкторы

Конструктор и Описание
ScheduledThreadPoolExecutor(int corePoolSize) Создает новое ScheduledThreadPoolExecutor с данным ядром объединяют размер в пул.
ScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler) Создает новый ScheduledThreadPoolExecutor с данными начальными параметрами.
ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory) Создает новое ScheduledThreadPoolExecutor с данными начальными параметрами.
ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler) Создает новый ScheduledThreadPoolExecutor с данными начальными параметрами.

Сводка метода

Методы

Модификатор и Тип	Метод и Описание
protected <V> RunnableScheduledFuture<V>	decorateTask(Callable<V> callable, RunnableScheduledFuture<V> task) Изменяет или заменяет задачу, используемую, чтобы выполнить вызываемое.
protected <V> RunnableScheduledFuture<V>	decorateTask(Runnable runnable, RunnableScheduledFuture<V> task) Изменяет или заменяет задачу, используемую, чтобы выполнить выполнимое.
void	execute(Runnable command) Выполняется command с нулем требуемая задержка.
boolean	getContinueExistingPeriodicTasksAfterShutdownPolicy() Надевает политику, продолжать ли выполнять существующие периодические задачи, даже когда этот исполнитель был shutdown.
boolean	getExecuteExistingDelayedTasksAfterShutdownPolicy() Надевает политику, выполнить ли существующие задержанные задачи, даже когда этот исполнитель был shutdown.
BlockingQueue<Runnable>	getQueue() Возвращает очередь задачи, используемую этим исполнителем.
boolean	getRemoveOnCancelPolicy() Надевает политику, должны ли отмененные задачи быть сразу удалены из рабочего списка во время отмены.
<V> ScheduledFuture<V>	schedule(Callable<V> callable, long delay, TimeUnit unit) Создает и выполняет ScheduledFuture, который становится включенным после данной задержки.
ScheduledFuture<?>	schedule(Runnable command, 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) Создает и выполняет периодическое действие, которое становится включенным сначала после данной начальной задержки, и впоследствии с данной задержкой между завершением одного выполнения и началом следующего.
void	setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value) Устанавливает политику по тому, продолжать ли выполнять существующие периодические задачи, даже когда этот исполнитель был shutdown.
void	setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value) Устанавливает политику по тому, выполнить ли существующие задержанные задачи, даже когда этот исполнитель был shutdown.
void	setRemoveOnCancelPolicy(boolean value) Устанавливает политику по тому, должны ли отмененные задачи быть сразу удалены из рабочего списка во время отмены.
void	shutdown() Инициирует аккуратное завершение работы, на котором выполняются ранее представленные задачи, но никакие новые задачи не будут приняты.
List<Runnable>	shutdownNow() Попытки остановить все активно выполняющиеся задачи, останавливает обработку ожидающих задач, и возвращает список задач, которые ждали выполнения.
<T> Future<T>	submit(Callable<T> task) Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи.
Future<?>	submit(Runnable task) Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.
<T> Future<T>	submit(Runnable task, T result) Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу.

Методы java.util.concurrent унаследованный от класса. ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString

Методы, унаследованные от класса java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Методы java.lang унаследованный от класса. Объект

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Деталь конструктора

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize)

Создает новое ScheduledThreadPoolExecutor с данным ядром объединяют размер в пул.

Параметры:

corePoolSize - число потоков, чтобы сохранить в пуле, даже если они не неактивны, если allowCoreThreadTimeOut устанавливается

Броски:

IllegalArgumentException - если corePoolSize < 0

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                           ThreadFactory threadFactory)

Создает новое ScheduledThreadPoolExecutor с данными начальными параметрами.

Параметры:

corePoolSize - число потоков, чтобы сохранить в пуле, даже если они не неактивны, если allowCoreThreadTimeOut устанавливается

threadFactory - фабрика, чтобы использовать, когда исполнитель создает новый поток

Броски:

IllegalArgumentException - если corePoolSize < 0

NullPointerException - если threadFactory нуль

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                           RejectedExecutionHandler handler)

Создает новый ScheduledThreadPoolExecutor с данными начальными параметрами.

Параметры:

corePoolSize - число потоков, чтобы сохранить в пуле, даже если они не неактивны, если allowCoreThreadTimeOut устанавливается

handler - обработчик, чтобы использовать, когда выполнение блокируется, потому что границы потока и емкости очереди достигаются

Броски:

IllegalArgumentException - если corePoolSize < 0

NullPointerException - если handler нуль

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                           ThreadFactory threadFactory,
                           RejectedExecutionHandler handler)

Создает новый ScheduledThreadPoolExecutor с данными начальными параметрами.

Параметры:

corePoolSize - число потоков, чтобы сохранить в пуле, даже если они не неактивны, если allowCoreThreadTimeOut устанавливается

threadFactory - фабрика, чтобы использовать, когда исполнитель создает новый поток

handler - обработчик, чтобы использовать, когда выполнение блокируется, потому что границы потока и емкости очереди достигаются

Броски:

IllegalArgumentException - если corePoolSize < 0

NullPointerException - если threadFactory или handler нуль

Деталь метода

decorateTask

protected <V> RunnableScheduledFuture<V> decorateTask(Runnable runnable,
                                          RunnableScheduledFuture<V> task)

Изменяет или заменяет задачу, используемую, чтобы выполнить выполнимое. Этот метод может использоваться, чтобы переопределить реальный класс, используемый для того, чтобы управлять внутренними задачами. Реализация по умолчанию просто возвращает данную задачу.

Параметры:

runnable - представленное Выполнимое

task - задача, создаваемая, чтобы выполнить выполнимое

Возвраты:

задача, которая может выполнить выполнимое

С тех пор:

1.6

decorateTask

protected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> callable,
                                          RunnableScheduledFuture<V> task)

Изменяет или заменяет задачу, используемую, чтобы выполнить вызываемое. Этот метод может использоваться, чтобы переопределить реальный класс, используемый для того, чтобы управлять внутренними задачами. Реализация по умолчанию просто возвращает данную задачу.

Параметры:

callable - представленное Вызываемое

task - задача, создаваемая, чтобы выполнить вызываемое

Возвраты:

задача, которая может выполнить вызываемое

С тех пор:

1.6

расписание

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

Описание скопировало с интерфейса: ScheduledExecutorService

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

Определенный:

schedule в интерфейсе ScheduledExecutorService

Параметры:

command - задача выполниться

delay - время с этого времени, чтобы задержать выполнение

unit - единица измерения времени параметра задержки

Возвраты:

завершение представления ScheduledFuture на ожидании задачи и чей метод get() возвратит null после завершения

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если команда является нулем

расписание

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

Описание скопировало с интерфейса: ScheduledExecutorService

Создает и выполняет ScheduledFuture, который становится включенным после данной задержки.

Определенный:

schedule в интерфейсе ScheduledExecutorService

Параметры:

callable - функция, чтобы выполниться

delay - время с этого времени, чтобы задержать выполнение

unit - единица измерения времени параметра задержки

Возвраты:

ScheduledFuture, который может использоваться, чтобы извлечь результат или отмену

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если вызываемый нуль

scheduleAtFixedRate

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

Описание скопировало с интерфейса: ScheduledExecutorService

Создает и выполняет периодическое действие, которое становится включенным сначала после данной начальной задержки, и впоследствии с установленным сроком; это - выполнение, начнется после initialDelay тогда initialDelay+period, тогда initialDelay + 2 * period, и так далее. Если какое-либо выполнение задачи встречается с исключением, последующее выполнение подавляется. Иначе, задача только завершится через отмену или завершение исполнителя. Если какое-либо выполнение этой задачи занимает больше времени чем ее период, то последующее выполнение может запуститься поздно, но не будет одновременно выполняться.

Определенный:

scheduleAtFixedRate в интерфейсе ScheduledExecutorService

Параметры:

command - задача выполниться

initialDelay - время, чтобы задержать первое выполнение

period - период между последовательным выполнением

unit - единица измерения времени initialDelay и параметров периода

Возвраты:

завершение представления ScheduledFuture на ожидании задачи, и чей метод get() выдаст исключение на отмену

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если команда является нулем

IllegalArgumentException - если период, меньше чем или равный нулю

scheduleWithFixedDelay

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

Описание скопировало с интерфейса: ScheduledExecutorService

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

Определенный:

scheduleWithFixedDelay в интерфейсе ScheduledExecutorService

Параметры:

command - задача выполниться

initialDelay - время, чтобы задержать первое выполнение

delay - задержка между завершением одного выполнения и началом следующего

unit - единица измерения времени initialDelay и параметров задержки

Возвраты:

завершение представления ScheduledFuture на ожидании задачи, и чей метод get() выдаст исключение на отмену

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если команда является нулем

IllegalArgumentException - если задержка, меньше чем или равная нулю

выполниться

public void execute(Runnable command)

Выполняется command с нулем требуемая задержка. Это имеет эффект, эквивалентный schedule(command, 0, anyUnit). Отметьте что контроли очереди и списка, возвращенного shutdownNow получит доступ к задержанному нулем ScheduledFuture, не command непосредственно.

Последствие использования ScheduledFuture объекты - это afterExecute всегда вызывается с нулевой секундой Throwable параметр, даже если command завершенный резко. Вместо этого Throwable брошенный такой задачей может быть получен через Future.get().

Определенный:

execute в интерфейсе Executor

Переопределения:

execute в классе ThreadPoolExecutor

Параметры:

command - задача выполниться

Броски:

RejectedExecutionException - по усмотрению RejectedExecutionHandler, если задача не может быть принята для выполнения, потому что исполнитель был выключен

NullPointerException - если command нуль

подчиниться

public Future<?> submit(Runnable task)

Описание скопировало с интерфейса: ExecutorService

Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит null после успешного завершения.

Определенный:

submit в интерфейсе ExecutorService

Переопределения:

submit в классе AbstractExecutorService

Параметры:

task - задача подчиниться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

подчиниться

public <T> Future<T> submit(Runnable task,
                   T result)

Описание скопировало с интерфейса: ExecutorService

Представляет Выполнимую задачу для выполнения и возвращает Будущее, представляющее ту задачу. Метод get Будущего возвратит данный результат после успешного завершения.

Определенный:

submit в интерфейсе ExecutorService

Переопределения:

submit в классе AbstractExecutorService

Параметры:

task - задача подчиниться

result - результат возвратиться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

подчиниться

public <T> Future<T> submit(Callable<T> task)

Описание скопировало с интерфейса: ExecutorService

Представляет возвращающую значение задачу для выполнения и возвращает Будущее, представляющее результаты на ожидании задачи. Метод get Будущего возвратит результат задачи после успешного завершения.

Если требуется сразу блокировать ожидание задачи, можно использовать конструкции формы result = exec.submit(aCallable).get();

Отметьте: Executors класс включает ряд методов, которые могут преобразовать некоторые другие общие подобные закрытию объекты, например, PrivilegedAction к Callable сформируйтесь, таким образом, они могут быть представлены.

Определенный:

submit в интерфейсе ExecutorService

Переопределения:

submit в классе AbstractExecutorService

Параметры:

task - задача подчиниться

Возвраты:

Будущее представление завершение на ожидании задачи

Броски:

RejectedExecutionException - если задача не может быть запланирована для выполнения

NullPointerException - если задачей является нуль

setContinueExistingPeriodicTasksAfterShutdownPolicy

public void setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)

Устанавливает политику по тому, продолжать ли выполнять существующие периодические задачи, даже когда этот исполнитель был shutdown. В этом случае эти задачи только завершатся на shutdownNow или после установки политики к false когда уже завершают работу. Это значение по умолчанию false.

Параметры:

value - если true, продолжайте после завершения работы, еще не делайте.

См. Также:

getContinueExistingPeriodicTasksAfterShutdownPolicy()

getContinueExistingPeriodicTasksAfterShutdownPolicy

public boolean getContinueExistingPeriodicTasksAfterShutdownPolicy()

Надевает политику, продолжать ли выполнять существующие периодические задачи, даже когда этот исполнитель был shutdown. В этом случае эти задачи только завершатся на shutdownNow или после установки политики к false когда уже завершают работу. Это значение по умолчанию false.

Возвраты:

true если будет продолжаться после завершения работы

См. Также:

setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean)

setExecuteExistingDelayedTasksAfterShutdownPolicy

public void setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value)

Устанавливает политику по тому, выполнить ли существующие задержанные задачи, даже когда этот исполнитель был shutdown. В этом случае эти задачи только завершатся на shutdownNow, или после установки политики к false когда уже завершают работу. Это значение по умолчанию true.

Параметры:

value - если true, выполнитесь после завершения работы, еще не делайте.

См. Также:

getExecuteExistingDelayedTasksAfterShutdownPolicy()

getExecuteExistingDelayedTasksAfterShutdownPolicy

public boolean getExecuteExistingDelayedTasksAfterShutdownPolicy()

Надевает политику, выполнить ли существующие задержанные задачи, даже когда этот исполнитель был shutdown. В этом случае эти задачи только завершатся на shutdownNow, или после установки политики к false когда уже завершают работу. Это значение по умолчанию true.

Возвраты:

true если выполнится после завершения работы

См. Также:

setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean)

setRemoveOnCancelPolicy

public void setRemoveOnCancelPolicy(boolean value)

Устанавливает политику по тому, должны ли отмененные задачи быть сразу удалены из рабочего списка во время отмены. Это значение по умолчанию false.

Параметры:

value - если true, удалите на отмене, еще не делайте

С тех пор:

1.7

См. Также:

getRemoveOnCancelPolicy()

getRemoveOnCancelPolicy

public boolean getRemoveOnCancelPolicy()

Надевает политику, должны ли отмененные задачи быть сразу удалены из рабочего списка во время отмены. Это значение по умолчанию false.

Возвраты:

true если отмененные задачи были сразу удалены из очереди

С тех пор:

1.7

См. Также:

setRemoveOnCancelPolicy(boolean)

завершение работы

public void shutdown()

Инициирует аккуратное завершение работы, на котором выполняются ранее представленные задачи, но никакие новые задачи не будут приняты. Вызов не имеет никакого дополнительного эффекта если уже выключенный.

Этот метод не ожидает ранее представленных задач завершить выполнение. Использовать awaitTermination сделать это.

Если ExecuteExistingDelayedTasksAfterShutdownPolicy был установлен false, отменяются существующие задержанные задачи, задержки которых еще не протекли. И если ContinueExistingPeriodicTasksAfterShutdownPolicy был установлен true, будет отменено будущее выполнение существующих периодических задач.

Определенный:

shutdown в интерфейсе ExecutorService

Переопределения:

shutdown в классе ThreadPoolExecutor

Броски:

SecurityException - если менеджер безопасности существует, и завершающий работу этого ExecutorService может управлять потоками, которые вызывающей стороне не разрешают изменить, потому что это не содержит RuntimePermission("modifyThread"), или метод checkAccess менеджера безопасности лишает доступа.

shutdownNow

public List<Runnable> shutdownNow()

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

Этот метод не ожидает активного выполнения задач завершиться. Использовать awaitTermination сделать это.

Нет никаких гарантий вне попыток максимальных усилий прекратить обрабатывать активно выполняющиеся задачи. Эта реализация отменяет задачи через Thread.interrupt(), таким образом, любая задача, которая не в состоянии ответить на прерывания, никогда, возможно, не завершается.

Определенный:

shutdownNow в интерфейсе ExecutorService

Переопределения:

shutdownNow в классе ThreadPoolExecutor

Возвраты:

список задач это никогда не начинало выполнение. Каждый элемент этого списка является a ScheduledFuture, включая те задачи, представленные, используя execute, которые являются для того, чтобы запланировать цели, используемые в качестве основания нулевой задержки ScheduledFuture.

Броски:

SecurityException - если менеджер безопасности существует, и завершающий работу этого ExecutorService может управлять потоками, которые вызывающей стороне не разрешают изменить, потому что это не содержит RuntimePermission("modifyThread"), или метод checkAccess менеджера безопасности лишает доступа.

getQueue

public BlockingQueue<Runnable> getQueue()

Возвращает очередь задачи, используемую этим исполнителем. Каждый элемент этой очереди является a ScheduledFuture, включая те задачи, представленные, используя execute которые являются для того, чтобы запланировать цели, используемые в качестве основания нулевой задержки ScheduledFuture. Итерация по этой очереди, как гарантируют, не пересечет задачи в порядке, в котором они выполнятся.

Переопределения:

getQueue в классе ThreadPoolExecutor

Возвраты:

очередь задачи