ForkJoinWorkerThread
Stay organized with collections
Save and categorize content based on your preferences.
A thread managed by a ForkJoinPool
, which executes
ForkJoinTask
s.
This class is subclassable solely for the sake of adding
functionality -- there are no overridable methods dealing with
scheduling or execution. However, you can override initialization
and termination methods surrounding the main task processing loop.
If you do create such a subclass, you will also need to supply a
custom ForkJoinPool.ForkJoinWorkerThreadFactory
to
{@linkplain ForkJoinPool#ForkJoinPool use it} in a ForkJoinPool
.
Inherited Constant Summary
From class
java.lang.Thread
int |
MAX_PRIORITY |
|
int |
MIN_PRIORITY |
|
int |
NORM_PRIORITY |
|
Protected Constructor Summary
Public Method Summary
ForkJoinPool
|
getPool()
Returns the pool hosting this thread.
|
int
|
getPoolIndex()
Returns the unique index number of this thread in its pool.
|
void
|
run()
This method is required to be public, but should never be
called explicitly.
|
Protected Method Summary
void
|
onStart()
Initializes internal state after construction but before
processing any tasks.
|
void
|
|
Inherited Method Summary
From class
java.lang.Thread
static
int
|
activeCount()
|
final
void
|
checkAccess()
|
Object
|
clone()
Creates and returns a copy of this Object .
|
int
|
countStackFrames()
|
static
Thread
|
currentThread()
|
void
|
destroy()
|
static
void
|
dumpStack()
|
static
int
|
enumerate(Thread[] arg0)
|
static
Map<Thread, StackTraceElement[]>
|
getAllStackTraces()
|
ClassLoader
|
getContextClassLoader()
|
static
Thread.UncaughtExceptionHandler
|
getDefaultUncaughtExceptionHandler()
|
long
|
getId()
|
final
String
|
getName()
|
final
int
|
getPriority()
|
StackTraceElement[]
|
getStackTrace()
|
Thread.State
|
getState()
|
final
ThreadGroup
|
getThreadGroup()
|
Thread.UncaughtExceptionHandler
|
getUncaughtExceptionHandler()
|
long
|
googleGetContext0()
|
void
|
googleSetContext0(long arg0)
|
static
boolean
|
|
void
|
interrupt()
|
static
boolean
|
interrupted()
|
final
boolean
|
isAlive()
|
final
boolean
|
isDaemon()
|
boolean
|
isInterrupted()
|
final
void
|
join()
|
synchronized
final
void
|
join(long arg0)
|
synchronized
final
void
|
join(long arg0, int arg1)
|
final
void
|
resume()
|
void
|
run()
When an object implementing interface Runnable is used
to create a thread, starting the thread causes the object's
run method to be called in that separately executing
thread.
|
void
|
|
final
void
|
setDaemon(boolean arg0)
|
static
void
|
setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler arg0)
|
synchronized
final
void
|
|
final
void
|
setPriority(int arg0)
|
void
|
setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler arg0)
|
static
void
|
sleep(long arg0, int arg1)
|
static
void
|
sleep(long arg0)
|
synchronized
void
|
start()
|
final
void
|
stop()
|
synchronized
final
void
|
|
final
void
|
suspend()
|
String
|
toString()
Returns a string containing a concise, human-readable description of this
object.
|
static
void
|
yield()
|
From class
java.lang.Object
Object
|
clone()
Creates and returns a copy of this Object .
|
boolean
|
equals( Object obj)
Compares this instance with the specified object and indicates if they
are equal.
|
void
|
finalize()
Invoked when the garbage collector has detected that this instance is no longer reachable.
|
final
Class<?>
|
getClass()
Returns the unique instance of Class that represents this
object's class.
|
int
|
hashCode()
Returns an integer hash code for this object.
|
final
void
|
notify()
Causes a thread which is waiting on this object's monitor (by means of
calling one of the wait() methods) to be woken up.
|
final
void
|
notifyAll()
Causes all threads which are waiting on this object's monitor (by means
of calling one of the wait() methods) to be woken up.
|
String
|
toString()
Returns a string containing a concise, human-readable description of this
object.
|
final
void
|
wait(long timeout, int nanos)
Causes the calling thread to wait until another thread calls the notify() or notifyAll() method of this object or until the
specified timeout expires.
|
final
void
|
wait(long timeout)
Causes the calling thread to wait until another thread calls the notify() or notifyAll() method of this object or until the
specified timeout expires.
|
final
void
|
wait()
Causes the calling thread to wait until another thread calls the notify() or notifyAll() method of this object.
|
From interface
java.lang.Runnable
abstract
void
|
run()
When an object implementing interface Runnable is used
to create a thread, starting the thread causes the object's
run method to be called in that separately executing
thread.
|
Protected Constructors
protected
ForkJoinWorkerThread
(ForkJoinPool pool)
Creates a ForkJoinWorkerThread operating in the given pool.
Parameters
pool |
the pool this thread works in |
Public Methods
Returns the pool hosting this thread.
public
int
getPoolIndex
()
Returns the unique index number of this thread in its pool.
The returned value ranges from zero to the maximum number of
threads (minus one) that may exist in the pool, and does not
change during the lifetime of the thread. This method may be
useful for applications that track status or collect results
per-worker-thread rather than per-task.
public
void
run
()
This method is required to be public, but should never be
called explicitly. It performs the main run loop to execute
ForkJoinTask
s.
Protected Methods
protected
void
onStart
()
Initializes internal state after construction but before
processing any tasks. If you override this method, you must
invoke super.onStart()
at the beginning of the method.
Initialization requires care: Most fields must have legal
default values, to ensure that attempted accesses from other
threads work correctly even before this thread starts
processing tasks.
protected
void
onTermination
(Throwable exception)
Performs cleanup associated with termination of this worker
thread. If you override this method, you must invoke
super.onTermination
at the end of the overridden method.
Parameters
exception |
the exception causing this thread to abort due
to an unrecoverable error, or null if completed normally
|
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2021-04-08 UTC.
[{
"type": "thumb-down",
"id": "missingTheInformationINeed",
"label":"Missing the information I need"
},{
"type": "thumb-down",
"id": "tooComplicatedTooManySteps",
"label":"Too complicated / too many steps"
},{
"type": "thumb-down",
"id": "outOfDate",
"label":"Out of date"
},{
"type": "thumb-down",
"id": "samplesCodeIssue",
"label":"Samples / code issue"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]