Класс ForkJoinPool

public static final ForkJoinPool.ForkJoinWorkerThreadFactory defaultForkJoinWorkerThreadFactory

public ForkJoinPool()

public ForkJoinPool(int parallelism)

Параметры:

parallelism - уровень параллелизма

Исключения:

IllegalArgumentException - если уровень параллелизма меньше или равен нулю, или больше предела реализации

public ForkJoinPool(int parallelism, ForkJoinPool.ForkJoinWorkerThreadFactory factory, Thread.UncaughtExceptionHandler handler, boolean asyncMode)

Параметры:

parallelism - уровень параллелизма. Для значения по умолчанию используйте Runtime.availableProcessors().

factory - фабрика для создания новых потоков. Для значения по умолчанию используйте defaultForkJoinWorkerThreadFactory.

handler - обработчик для внутренних рабочих потоков, которые завершаются из-за непреодолимых ошибок, возникающих при выполнении задач. Для значения по умолчанию используйте null.

asyncMode - если true, устанавливает локальный режим планирования FIFO для разветвлённых задач, которые никогда не объединяются. Этот режим может быть более подходящим, чем режим по умолчанию на основе локального стека в приложениях, в которых рабочие потоки обрабатывают только асинхронные задачи типа событий. Для значения по умолчанию используйте false.

Исключения:

IllegalArgumentException - если уровень параллелизма меньше или равен нулю, или больше предела реализации

NullPointerException - если фабрика равна null

public ForkJoinPool(int parallelism, ForkJoinPool.ForkJoinWorkerThreadFactory factory, Thread.UncaughtExceptionHandler handler, boolean asyncMode, int corePoolSize, int maximumPoolSize, int minimumRunnable, Predicate<? super ForkJoinPool> saturate, long keepAliveTime, TimeUnit unit)

Параметры:

parallelism — уровень параллелизма. Для значения по умолчанию используйте Runtime.availableProcessors().

factory — фабрика для создания новых потоков. Для значения по умолчанию используйте defaultForkJoinWorkerThreadFactory.

handler — обработчик для внутренних рабочих потоков, которые завершаются из-за невосстановимых ошибок, возникших во время выполнения задач. Для значения по умолчанию используйте null.

asyncMode — если true, устанавливает локальный режим планирования «первый пришёл — первый обслужен» для разветвлённых задач, которые никогда не присоединяются. Этот режим может быть более подходящим, чем режим по умолчанию, основанный на локальном стеке, в приложениях, в которых рабочие потоки обрабатывают только асинхронные задачи типа событий. Для значения по умолчанию используйте false.

corePoolSize — количество потоков, которые необходимо поддерживать в пуле (если они не отключаются после истечения времени ожидания). Обычно (и по умолчанию) это значение такое же, как и уровень параллелизма, но может быть установлено большим значением, чтобы уменьшить динамическую нагрузку, если задачи регулярно блокируются. Использование меньшего значения (например, 0) имеет тот же эффект, что и по умолчанию.

maximumPoolSize — максимальное количество разрешённых потоков. Когда максимум достигнут, попытки заменить заблокированные потоки терпят неудачу. (Однако, поскольку создание и завершение различных потоков могут перекрываться и могут управляться заданной фабрикой потоков, это значение может временно превышаться.) Чтобы установить такое же значение, как используется по умолчанию для общего пула, используйте 256 плюс parallelism уровень. (По умолчанию общий пул допускает максимум 256 резервных потоков.) Использование значения (например, Integer.MAX_VALUE), большего, чем общий предел потоков реализации, имеет тот же эффект, что и использование этого предела (который является значением по умолчанию).

minimumRunnable — минимальное разрешённое число базовых потоков, не заблокированных объединением или ForkJoinPool.ManagedBlocker. Для обеспечения прогресса, когда существует слишком мало разблокированных потоков и могут существовать невыполненные задачи, создаются новые потоки до заданного максимального размера пула. Для значения по умолчанию используйте 1, что гарантирует жизнеспособность. Более высокое значение может улучшить пропускную способность при наличии заблокированных действий, но может и не сделать этого из-за увеличенной нагрузки. Значение ноль может быть приемлемым, когда отправленные задачи не могут иметь зависимости, требующие дополнительных потоков.

saturate — если не null, предикат, вызываемый при попытках создать больше, чем максимальное разрешённое количество потоков. По умолчанию, когда поток собирается заблокироваться на присоединении или ForkJoinPool.ManagedBlocker, но не может быть заменён, потому что maximumPoolSize будет превышен, выбрасывается RejectedExecutionException. Но если этот предикат возвращает true, исключение не выбрасывается, поэтому пул продолжает работать с меньшим, чем целевое, числом работающих потоков, что может не гарантировать прогресс.

keepAliveTime — время с момента последнего использования, прежде чем поток завершается (а затем позже заменяется при необходимости). Для значения по умолчанию используйте 60, TimeUnit.SECONDS.

unit — единица измерения времени для аргумента keepAliveTime

Исключения:

IllegalArgumentException — если уровень параллелизма меньше или равен нулю, или превышает предел реализации, или если maximumPoolSize меньше parallelism, или если keepAliveTime меньше или равно нулю.

NullPointerException — если factory равно null

С:

9

public static ForkJoinPool commonPool()

Возвращает:

экземпляр общего пула

С:

1.8

public <T> T invoke(ForkJoinTask<T> task)

Параметры типа:

T - тип результата задачи

Параметры:

task - задача

Возвращает:

результат задачи

Исключения:

NullPointerException - если задача равна null

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

public void execute(ForkJoinTask<?> task)

Параметры:

task - задача

Исключения:

NullPointerException - если задача равна null

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

public void execute(Runnable task)

Параметры:

task - задача Runnable

Исключения:

NullPointerException - если задача равна null

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

public <T> ForkJoinTask<T> submit(ForkJoinTask<T> task)

Требования к реализации:

Этот метод эквивалентен externalSubmit(ForkJoinTask), когда вызывается из потока, который не находится в этом пуле.

Параметры типа:

T - тип результата задачи

Параметры:

task - задача для отправки

Возвращает:

задачу

Исключения:

NullPointerException - если задача равна null

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

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

Задано:

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

Переопределяет:

submit в классе AbstractExecutorService

Параметры типа:

T - тип результата задачи

Параметры:

task - задача для отправки

Возвращает:

Future, представляющая ожидаемое завершение задачи

Исключения:

NullPointerException - если задача равна null

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

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

Определено в:

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

Переопределено в:

submit в классе AbstractExecutorService

Параметры типа:

T - тип результата

Параметры:

task - задача для отправки

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

Возвращает:

Future, представляющий ожидаемое завершение задачи

Исключения:

NullPointerException - если задача равна null

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

public ForkJoinTask<?> submit(Runnable task)

Определено в:

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

Переопределено в:

submit в классе AbstractExecutorService

Параметры:

task - задача для отправки

Возвращает:

Future, представляющий ожидаемое завершение задачи

Исключения:

NullPointerException - если задача равна null

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

public <T> ForkJoinTask<T> externalSubmit(ForkJoinTask<T> task)

Требования к реализации:

Этот метод эквивалентен submit(ForkJoinTask), если вызывается из потока, который не принадлежит этому пулу.

Параметры типа:

T - тип результата задачи

Параметры:

task - задача для отправки

Возвращает:

задачу

Исключения:

NullPointerException - если задача равна null

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

С:

20

public <T> ForkJoinTask<T> lazySubmit(ForkJoinTask<T> task)

Параметры типа:

T - тип результата задачи

Параметры:

task - задача

Возвращает:

задачу

Исключения:

NullPointerException - если задача равна null

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

С:

19

public int setParallelism(int size)

Примечание реализации:

Эта реализация ограничивает максимальное количество запущенных потоков 32767

Параметры:

size - целевой уровень параллельности

Возвращает:

предыдущий уровень параллельности.

Исключения:

IllegalArgumentException - если размер меньше 1 или больше максимального, поддерживаемого этим пулом.

UnsupportedOperationException - это commonPool() и уровень параллельности был задан системной переменной java.util.concurrent.ForkJoinPool.common.parallelism.

С:

19

public <T> List<Future<T>> invokeAllUninterruptibly(Collection<? extends Callable<T>> tasks)

Примечание API:

Этот метод поддерживает использование, которое ранее полагалось на несовместимую переопределённую версию ExecutorService.invokeAll(java.util.Collection).

Параметры типа:

T - тип значений, возвращаемых задачами

Параметры:

tasks - коллекция задач

Возвращает:

список Futures, представляющих задачи в том же последовательном порядке, что и итератор для данного списка задач, каждая из которых завершилась

Исключения:

NullPointerException - если задачи или какой-либо из их элементов являются null

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

С:

22

public ForkJoinPool.ForkJoinWorkerThreadFactory getFactory()

Возвращает:

фабрика, используемая для создания новых рабочих потоков

public Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

Возвращает:

обработчик, или null, если он отсутствует

public int getParallelism()

Возвращает:

целевой уровень параллельности этого пула

public static int getCommonPoolParallelism()

Возвращает:

целевой уровень параллельности общего пула

С:

1.8

public int getPoolSize()

Возвращает:

количество рабочих потоков

public boolean getAsyncMode()

Возвращает:

true, если этот пул использует асинхронный режим

public int getRunningThreadCount()

Возвращает:

количество рабочих потоков

public int getActiveThreadCount()

Возвращает:

количество активных потоков

public boolean isQuiescent()

Возвращает:

true, если все потоки в данный момент бездействуют

public long getStealCount()

Возвращает:

количество краж

public long getQueuedTaskCount()

Возвращает:

количество задач в очереди

См. также:

• ForkJoinWorkerThread.getQueuedTaskCount()

public int getQueuedSubmissionCount()

Возвращает:

количество задач в очереди

public boolean hasQueuedSubmissions()

Возвращает:

true, если есть задачи в очереди

protected ForkJoinTask<?> pollSubmission()

Возвращает:

следующую отправку или null, если нет

protected int drainTasksTo(Collection<? super ForkJoinTask<?>> c)

Параметры:

c - набор для переноса элементов

Возвращает:

количество перенесённых элементов

public String toString()

Переопределяет:

toString в классе Object

Возвращает:

строку, идентифицирующую этот пул, а также его состояние

public void shutdown()

public List<Runnable> shutdownNow()

Возвращает:

пустой список

public boolean isTerminated()

Возвращает:

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

public boolean isTerminating()

Возвращает:

true, если завершается, но еще не завершен

public boolean isShutdown()

Возвращает:

true, если этот пул был остановлен

public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException

Параметры:

timeout - максимальное время ожидания

unit - единица измерения времени для аргумента таймаута

Возвращает:

true, если этот исполнитель завершился, и false, если таймаут истек до завершения

Исключения:

InterruptedException - если произошел перерыв во время ожидания

public boolean awaitQuiescence(long timeout, TimeUnit unit)

Параметры:

timeout - максимальное время ожидания

unit - единица измерения времени для аргумента таймаута

Возвращает:

true, если пул в состоянии покоя; false, если таймаут истек.

public void close()

С:

19

public static void managedBlock(ForkJoinPool.ManagedBlocker blocker) throws InterruptedException

 
 while (!blocker.isReleasable())
   if (blocker.block())
     break;

Параметры:

blocker - задача блокирования

Исключения:

InterruptedException - если blocker.block() сделал это