Класс ForkJoinWorkerThread

Все реализованные интерфейсы:
Runnable
public class ForkJoinWorkerThread
extends Thread

Поток, управляемый ForkJoinPool, который выполняет задачи ForkJoinTask. Этот класс можно наследовать только для добавления функциональности — нет переопределяемых методов, связанных с планированием или выполнением. Однако вы можете переопределить методы инициализации и завершения, окружающие основной цикл обработки задач. Если вы создаёте такой подкласс, вам также потребуется предоставить настраиваемый ForkJoinPool.ForkJoinWorkerThreadFactory для его использования в ForkJoinPool.

С момента:
1.7

Вложенные классы

Вложенные классы/интерфейсы, объявленные в классе java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Поля

Поля, объявленные в классе java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Краткое описание конструкторов

Модификатор Конструктор Описание
protected ForkJoinWorkerThread​(ForkJoinPool pool)

Создаёт ForkJoinWorkerThread, работающий в заданном пуле.

Краткое описание методов

Модификатор и тип Метод Описание
ForkJoinPool getPool()

Возвращает пул, в котором работает этот поток.

int getPoolIndex()

Возвращает уникальный индекс этого потока в его пуле.

protected void onStart()

Инициализирует внутреннее состояние после создания, но перед обработкой каких-либо задач.

protected void onTermination​(Throwable exception)

Выполняет очистку, связанную с завершением этого потока-работника.

void run()

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

Методы, объявленные в классе java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Методы, объявленные в классе java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Подробное описание конструкторов

ForkJoinWorkerThread

protected ForkJoinWorkerThread(ForkJoinPool pool)

Создаёт ForkJoinWorkerThread, работающий в заданном пуле.

Параметры:
pool — пул, в котором работает этот поток
Исключения:
NullPointerException — если пул равен null

Подробное описание методов

getPool

public ForkJoinPool getPool()

Возвращает пул, в котором работает этот поток.

Возвращает:
пул

getPoolIndex

public int getPoolIndex()

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

Возвращает:
индекс

onStart

protected void onStart()

Инициализирует внутреннее состояние после создания, но перед обработкой каких-либо задач. Если вы переопределяете этот метод, вы должны вызвать super.onStart() в начале метода. Инициализация требует тщательности: большинство полей должны иметь допустимые значения по умолчанию, чтобы обеспечить корректную работу попыток доступа из других потоков даже до того, как этот поток начнёт обработку задач.

onTermination

protected void onTermination(Throwable exception)

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

Параметры:
exception — исключение, вызвавшее прерывание этого потока из-за неисправимой ошибки, или null если завершено нормально

run

public void run()

Этот метод должен быть публичным, но его никогда не следует вызывать явно. Он выполняет основной цикл выполнения для выполнения задач ForkJoinTask.

Определено в:
run в интерфейсе Runnable
Переопределяет:
run в классе Thread
См. также:
Thread.start(), Thread.stop(), Thread(ThreadGroup, Runnable, String)

© 1993, 2020, Oracle and/or its affiliates. All rights reserved.
Documentation extracted from Debian's OpenJDK Development Kit package.
Licensed under the GNU General Public License, version 2, with the Classpath Exception.
Various third party code in OpenJDK is licensed under different licenses (see Debian package).
Java and OpenJDK are trademarks or registered trademarks of Oracle and/or its affiliates.
https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/concurrent/ForkJoinWorkerThread.html

Spec-Zone .ru
спецификации, руководства, описания, API