Класс ForkJoinPool

defaultForkJoinWorkerThreadFactory

public static final ForkJoinPool.ForkJoinWorkerThreadFactory defaultForkJoinWorkerThreadFactory

ForkJoinPool

public ForkJoinPool()

Исключения:

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

ForkJoinPool

public ForkJoinPool(int parallelism)

Параметры:

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

Исключения:

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

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

ForkJoinPool

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

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

ForkJoinPool

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, устанавливает локальный режим планирования FIFO для разветвленных задач, которые никогда не объединяются. Этот режим может быть более подходящим, чем режим локальной стековой обработки по умолчанию в приложениях, в которых рабочие потоки обрабатывают только асинхронные задачи в стиле событий. Для значения по умолчанию используйте false.

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

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

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

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

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

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

Исключения:

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

NullPointerException - если фабричный метод равен null

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

С версии:

9

commonPool

public static ForkJoinPool commonPool()

Возвращает:

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

С версии:

1.8

invoke

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

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

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

Параметры:

task - задача

Возвращает:

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

Исключения:

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

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

execute

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)

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

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 - если задача не может быть запланирована для выполнения

invokeAll

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

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

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

Параметры:

tasks - список задач

Возвращает:

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

Исключения:

NullPointerException - если задачи или любые их элементы равны null

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

получитьФабрику

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()

Возвращает:

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

получитьКоличествоОжидающихОтправлений

public int getQueuedSubmissionCount()

Возвращает:

количество ожидающих отправлений

hasQueuedSubmissions

public boolean hasQueuedSubmissions()

Возвращает:

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

pollSubmission

protected ForkJoinTask<?> pollSubmission()

Возвращает:

следующую задачу или null , если нет

drainTasksTo

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

Параметры:

c - коллекция для передачи элементов

Возвращает:

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

toString

public String toString()

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

toString в классе Object

Возвращает:

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

shutdown

public void shutdown()

Выбрасывает:

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

shutdownNow

public List<Runnable> shutdownNow()

Возвращает:

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

Выбрасывает:

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

isTerminated

public boolean isTerminated()

Возвращает:

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

isTerminating

public boolean isTerminating()

Возвращает:

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

isShutdown

public boolean isShutdown()

Возвращает:

true , если этот пул задач был закрыт

awaitTermination

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

Параметры:

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

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

Возвращает:

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

Выбрасывает:

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

awaitQuiescence

public boolean awaitQuiescence(long timeout, TimeUnit unit)

Параметры:

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

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

Возвращает:

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

managedBlock

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

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

Параметры:

blocker - блокирующая задача

Выбрасывает:

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