class ForkJoinWorkerThread extends Thread
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 use it
in a ForkJoinPool
.
- Source
- ForkJoinWorkerThread.java
- Since
1.7
- Alphabetic
- By Inheritance
- ForkJoinWorkerThread
- Thread
- Runnable
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
ForkJoinWorkerThread(pool: ForkJoinPool)
- Attributes
- protected[akka.dispatch.forkjoin]
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to any2stringadd[ForkJoinWorkerThread] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (ForkJoinWorkerThread, B)
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to ArrowAssoc[ForkJoinWorkerThread] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
checkAccess(): Unit
- Definition Classes
- Thread
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- Thread → AnyRef
- Annotations
- @throws( ... )
-
def
ensuring(cond: (ForkJoinWorkerThread) ⇒ Boolean, msg: ⇒ Any): ForkJoinWorkerThread
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to Ensuring[ForkJoinWorkerThread] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (ForkJoinWorkerThread) ⇒ Boolean): ForkJoinWorkerThread
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to Ensuring[ForkJoinWorkerThread] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): ForkJoinWorkerThread
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to Ensuring[ForkJoinWorkerThread] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): ForkJoinWorkerThread
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to Ensuring[ForkJoinWorkerThread] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to StringFormat[ForkJoinWorkerThread] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
getContextClassLoader(): ClassLoader
- Definition Classes
- Thread
- Annotations
- @CallerSensitive()
-
def
getId(): Long
- Definition Classes
- Thread
-
final
def
getName(): String
- Definition Classes
- Thread
-
def
getPool(): ForkJoinPool
Returns the pool hosting this thread.
Returns the pool hosting this thread.
- returns
the pool
-
def
getPoolIndex(): Int
Returns the index number of this thread in its pool.
Returns the index number of this thread in its pool. The returned value ranges from zero to the maximum number of threads (minus one) that have ever been created in the pool. This method may be useful for applications that track status or collect results per-worker rather than per-task.
- returns
the index number
-
final
def
getPriority(): Int
- Definition Classes
- Thread
-
def
getStackTrace(): Array[StackTraceElement]
- Definition Classes
- Thread
-
def
getState(): State
- Definition Classes
- Thread
-
final
def
getThreadGroup(): ThreadGroup
- Definition Classes
- Thread
-
def
getUncaughtExceptionHandler(): UncaughtExceptionHandler
- Definition Classes
- Thread
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
interrupt(): Unit
- Definition Classes
- Thread
-
final
def
isAlive(): Boolean
- Definition Classes
- Thread
- Annotations
- @native()
-
final
def
isDaemon(): Boolean
- Definition Classes
- Thread
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isInterrupted(): Boolean
- Definition Classes
- Thread
-
final
def
join(): Unit
- Definition Classes
- Thread
- Annotations
- @throws( ... )
-
final
def
join(arg0: Long, arg1: Int): Unit
- Definition Classes
- Thread
- Annotations
- @throws( ... )
-
final
def
join(arg0: Long): Unit
- Definition Classes
- Thread
- Annotations
- @throws( ... )
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
onStart(): Unit
Initializes internal state after construction but before processing any tasks.
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.- Attributes
- protected[akka.dispatch.forkjoin]
-
def
onTermination(exception: Throwable): Unit
Performs cleanup associated with termination of this worker thread.
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.- exception
the exception causing this thread to abort due to an unrecoverable error, or
null
if completed normally
- Attributes
- protected[akka.dispatch.forkjoin]
-
def
run(): Unit
This method is required to be public, but should never be called explicitly.
This method is required to be public, but should never be called explicitly. It performs the main run loop to execute
ForkJoinTask
s.- Definition Classes
- ForkJoinWorkerThread → Thread → Runnable
-
def
setContextClassLoader(arg0: ClassLoader): Unit
- Definition Classes
- Thread
-
final
def
setDaemon(arg0: Boolean): Unit
- Definition Classes
- Thread
-
final
def
setName(arg0: String): Unit
- Definition Classes
- Thread
-
final
def
setPriority(arg0: Int): Unit
- Definition Classes
- Thread
-
def
setUncaughtExceptionHandler(arg0: UncaughtExceptionHandler): Unit
- Definition Classes
- Thread
-
def
start(): Unit
- Definition Classes
- Thread
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- Thread → AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (ForkJoinWorkerThread, B)
- Implicit
- This member is added by an implicit conversion from ForkJoinWorkerThread to ArrowAssoc[ForkJoinWorkerThread] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
Deprecated Value Members
-
def
countStackFrames(): Int
- Definition Classes
- Thread
- Annotations
- @native() @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
final
def
resume(): Unit
- Definition Classes
- Thread
- Annotations
- @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
final
def
stop(): Unit
- Definition Classes
- Thread
- Annotations
- @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
final
def
suspend(): Unit
- Definition Classes
- Thread
- Annotations
- @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.