Класс Executors

public static ExecutorService newFixedThreadPool(int nThreads)

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

public static ExecutorService newWorkStealingPool(int parallelism)

Создаёт пул потоков, который поддерживает достаточное количество потоков для заданного уровня параллелизма и может использовать несколько очередей для уменьшения конкуренции. Уровень параллелизма соответствует максимальному количеству потоков, активно участвующих или доступных для участия в обработке задач. Фактическое количество потоков может динамически увеличиваться и уменьшаться. Пул с похищением задач не даёт гарантий о порядке выполнения отправленных задач.

public static ExecutorService newWorkStealingPool()

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

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory)

Создаёт пул потоков, который повторно использует фиксированное количество потоков, работающих с общей неограниченной очередью, используя предоставленный ThreadFactory для создания новых потоков при необходимости. В любой момент времени не более nThreads потоков будут активны при обработке задач. Если дополнительные задачи отправляются, когда все потоки активны, они будут ожидать в очереди, пока не освободится поток. Если какой-либо поток завершается из-за ошибки во время выполнения до завершения, новый поток займёт его место при необходимости для выполнения последующих задач. Потоки в пуле будут существовать до явного shutdown.

public static ExecutorService newSingleThreadExecutor()

Создаёт Executor, использующий один рабочий поток, работающий с неограниченной очередью. (Обратите внимание, что если этот единственный поток завершится из-за ошибки во время выполнения до завершения, новый займёт его место при необходимости для выполнения последующих задач.) Задачи гарантированно выполняются последовательно, и не более одной задачи активна в любой момент времени. В отличие от newFixedThreadPool(1), возвращаемый executor не может быть переконфигурирован для использования дополнительных потоков.

public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory)

Создаёт Executor, использующий один рабочий поток, работающий с неограниченной очередью, и использующий предоставленный ThreadFactory для создания нового потока при необходимости. В отличие от newFixedThreadPool(1, threadFactory), возвращаемый executor не может быть переконфигурирован для использования дополнительных потоков.

public static ExecutorService newCachedThreadPool()

Создаёт пул потоков, который создаёт новые потоки по мере необходимости, но повторно использует ранее созданные потоки, когда они доступны. Эти пулы обычно улучшают производительность программ, выполняющих множество коротких асинхронных задач. Вызовы execute будут повторно использовать ранее созданные потоки, если они доступны. Если существующий поток недоступен, новый поток будет создан и добавлен в пул. Потоки, которые не использовались в течение шестидесяти секунд, завершаются и удаляются из кэша. Таким образом, пул, остающийся неактивным достаточно долго, не будет потреблять ресурсы. Обратите внимание, что пулы с аналогичными свойствами, но с другими деталями (например, параметрами таймаута) могут быть созданы с помощью конструкторов ThreadPoolExecutor.

public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory)

Создаёт пул потоков, который создаёт новые потоки по мере необходимости, но повторно использует ранее созданные потоки, когда они доступны, и использует предоставленный ThreadFactory для создания новых потоков при необходимости.

public static ExecutorService newThreadPerTaskExecutor(ThreadFactory threadFactory)

Создаёт Executor, который запускает новый поток для каждой задачи. Количество потоков, созданных Executor, не ограничено.

Вызов cancel(true) на Future, представляющем ожидаемый результат задачи, отправленной в Executor, приведет к interrupt потока, выполняющего задачу.

public static ExecutorService newVirtualThreadPerTaskExecutor()

Создаёт Executor, который запускает новый виртуальный поток для каждой задачи. Количество потоков, созданных Executor, не ограничено.

Этот метод эквивалентен вызову newThreadPerTaskExecutor(ThreadFactory) с фабрикой потоков, которая создаёт виртуальные потоки.

public static ScheduledExecutorService newSingleThreadScheduledExecutor()

Создаёт однопоточный executor, который может планировать выполнение команд после заданной задержки или периодически. (Обратите внимание, что если этот единственный поток завершится из-за ошибки во время выполнения до завершения, новый займёт его место при необходимости для выполнения последующих задач.) Задачи гарантированно выполняются последовательно, и не более одной задачи активна в любой момент времени. В отличие от newScheduledThreadPool(1), возвращаемый executor не может быть переконфигурирован для использования дополнительных потоков.

public static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory)

Создаёт однопоточный executor, который может планировать выполнение команд после заданной задержки или периодически. (Обратите внимание, что если этот единственный поток завершится из-за ошибки во время выполнения до завершения, новый займёт его место при необходимости для выполнения последующих задач.) Задачи гарантированно выполняются последовательно, и не более одной задачи активна в любой момент времени. В отличие от newScheduledThreadPool(1, threadFactory), возвращаемый executor не может быть переконфигурирован для использования дополнительных потоков.

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

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

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)

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

public static ExecutorService unconfigurableExecutorService(ExecutorService executor)

Возвращает объект, делегирующий все определённые ExecutorService методы заданному исполнителю, но не другие методы, которые могут быть доступны с помощью приведений типов. Это обеспечивает возможность безопасно "заморозить" конфигурацию и запретить настройку заданной конкретной реализации.

public static ScheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor)

Возвращает объект, делегирующий все определённые ScheduledExecutorService методы заданному исполнителю, но не другие методы, которые могут быть доступны с помощью приведений типов. Это обеспечивает возможность безопасно "заморозить" конфигурацию и запретить настройку заданной конкретной реализации.

public static ThreadFactory defaultThreadFactory()

Возвращает фабрику потоков по умолчанию, используемую для создания новых потоков. Эта фабрика создаёт все новые потоки, используемые Executor'ом, в той же ThreadGroup. Если есть SecurityManager, она использует группу System.getSecurityManager(), иначе группу потока, вызвавшего этот defaultThreadFactory метод. Каждый новый поток создаётся как не-демон-поток с приоритетом, равным меньшему из Thread.NORM_PRIORITY и максимальному приоритету, разрешённому в группе потоков. Имена новых потоков доступны через Thread.getName() и имеют вид pool-N-thread-M, где N — порядковый номер этой фабрики, а M — порядковый номер потока, созданного этой фабрикой.

@Deprecated(since="17", forRemoval=true) public static ThreadFactory privilegedThreadFactory()

Возвращает фабрику потоков, используемую для создания новых потоков с теми же правами, что и у текущего потока. Эта фабрика создаёт потоки с теми же настройками, что и defaultThreadFactory(), дополнительно устанавливая AccessControlContext и contextClassLoader новых потоков равными AccessControlContext и contextClassLoader потока, вызвавшего этот privilegedThreadFactory метод. Новый privilegedThreadFactory может быть создан в рамках действия AccessController.doPrivileged, устанавливающего контекст управления доступом текущего потока для создания потоков с выбранными настройками прав, действующими в рамках этого действия.

Обратите внимание, что, хотя задачи, выполняемые в таких потоках, будут иметь те же настройки управления доступом и загрузчика классов, что и текущий поток, у них могут быть не те же значения ThreadLocal или InheritableThreadLocal. При необходимости, конкретные значения потоковых локалей могут быть установлены или сброшены до выполнения любой задачи в подклассах ThreadPoolExecutor с помощью ThreadPoolExecutor.beforeExecute(Thread, Runnable). Также, если необходимо инициализировать рабочие потоки с теми же настройками InheritableThreadLocal, что и у какого-либо другого выделенного потока, можно создать пользовательскую ThreadFactory, в которой этот поток ожидает и обрабатывает запросы на создание других потоков, унаследовавших его значения.

public static <T> Callable<T> callable(Runnable task, T result)

Возвращает объект Callable, который при вызове выполняет заданную задачу и возвращает заданный результат. Это может быть полезно при применении методов, требующих Callable к действию, которое иначе не возвращает результат.

public static Callable<Object> callable(Runnable task)

Возвращает объект Callable, который при вызове выполняет заданную задачу и возвращает null.

public static Callable<Object> callable(PrivilegedAction<?> action)

Возвращает объект Callable, который при вызове выполняет заданное действие с привилегиями и возвращает его результат.

public static Callable<Object> callable(PrivilegedExceptionAction<?> action)

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

@Deprecated(since="17", forRemoval=true) public static <T> Callable<T> privilegedCallable(Callable<T> callable)

Возвращает объект Callable, который при вызове выполнит заданный callable в контексте текущего управления доступом. Этот метод обычно вызывается в рамках действия AccessController.doPrivileged для создания callable, который, если возможно, выполнится с выбранными настройками прав, действующими в рамках этого действия; или, если это невозможно, выбросит соответствующее AccessControlException.

@Deprecated(since="17", forRemoval=true) public static <T> Callable<T> privilegedCallableUsingCurrentClassLoader(Callable<T> callable)

Возвращает объект Callable, который при вызове выполнит заданный callable в контексте текущего управления доступом, используя текущий загрузчик контекста классов в качестве загрузчика контекста классов. Этот метод обычно вызывается в рамках действия AccessController.doPrivileged для создания callable, который, если возможно, выполнится с выбранными настройками прав, действующими в рамках этого действия; или, если это невозможно, выбросит соответствующее AccessControlException.