Класс 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 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 заданному executor, но не любые другие методы, которые могут быть доступны с помощью преобразований. Это предоставляет способ безопасно "заморозить" конфигурацию и запретить настройку заданной конкретной реализации.

public static ScheduledExecutorService unconfigurableScheduledExecutorService(ScheduledExecutorService executor)

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

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 новых потоков такими же, как у потока, вызывающего этот 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.