Packages

c

akka.dispatch.forkjoin

ForkJoinWorkerThread

class ForkJoinWorkerThread extends Thread

A thread managed by a ForkJoinPool, which executes ForkJoinTasks. 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

Linear Supertypes
Thread, Runnable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ForkJoinWorkerThread
  2. Thread
  3. Runnable
  4. AnyRef
  5. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ForkJoinWorkerThread(pool: ForkJoinPool)
    Attributes
    protected[akka.dispatch.forkjoin]

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. 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
  4. 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()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. final def checkAccess(): Unit
    Definition Classes
    Thread
  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    Thread → AnyRef
    Annotations
    @throws( ... )
  9. 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
  10. 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
  11. 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
  12. 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
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. 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()
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. def getContextClassLoader(): ClassLoader
    Definition Classes
    Thread
    Annotations
    @CallerSensitive()
  18. def getId(): Long
    Definition Classes
    Thread
  19. final def getName(): String
    Definition Classes
    Thread
  20. def getPool(): ForkJoinPool

    Returns the pool hosting this thread.

    Returns the pool hosting this thread.

    returns

    the pool

  21. 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

  22. final def getPriority(): Int
    Definition Classes
    Thread
  23. def getStackTrace(): Array[StackTraceElement]
    Definition Classes
    Thread
  24. def getState(): State
    Definition Classes
    Thread
  25. final def getThreadGroup(): ThreadGroup
    Definition Classes
    Thread
  26. def getUncaughtExceptionHandler(): UncaughtExceptionHandler
    Definition Classes
    Thread
  27. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  28. def interrupt(): Unit
    Definition Classes
    Thread
  29. final def isAlive(): Boolean
    Definition Classes
    Thread
    Annotations
    @native()
  30. final def isDaemon(): Boolean
    Definition Classes
    Thread
  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. def isInterrupted(): Boolean
    Definition Classes
    Thread
  33. final def join(): Unit
    Definition Classes
    Thread
    Annotations
    @throws( ... )
  34. final def join(arg0: Long, arg1: Int): Unit
    Definition Classes
    Thread
    Annotations
    @throws( ... )
  35. final def join(arg0: Long): Unit
    Definition Classes
    Thread
    Annotations
    @throws( ... )
  36. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  37. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  38. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  39. 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]
  40. 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]
  41. 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 ForkJoinTasks.

    Definition Classes
    ForkJoinWorkerThread → Thread → Runnable
  42. def setContextClassLoader(arg0: ClassLoader): Unit
    Definition Classes
    Thread
  43. final def setDaemon(arg0: Boolean): Unit
    Definition Classes
    Thread
  44. final def setName(arg0: String): Unit
    Definition Classes
    Thread
  45. final def setPriority(arg0: Int): Unit
    Definition Classes
    Thread
  46. def setUncaughtExceptionHandler(arg0: UncaughtExceptionHandler): Unit
    Definition Classes
    Thread
  47. def start(): Unit
    Definition Classes
    Thread
  48. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  49. def toString(): String
    Definition Classes
    Thread → AnyRef → Any
  50. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  52. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  53. 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

  1. def countStackFrames(): Int
    Definition Classes
    Thread
    Annotations
    @native() @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  2. 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.

  3. final def resume(): Unit
    Definition Classes
    Thread
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  4. final def stop(): Unit
    Definition Classes
    Thread
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  5. final def suspend(): Unit
    Definition Classes
    Thread
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from Thread

Inherited from Runnable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from ForkJoinWorkerThread to any2stringadd[ForkJoinWorkerThread]

Inherited by implicit conversion StringFormat from ForkJoinWorkerThread to StringFormat[ForkJoinWorkerThread]

Inherited by implicit conversion Ensuring from ForkJoinWorkerThread to Ensuring[ForkJoinWorkerThread]

Inherited by implicit conversion ArrowAssoc from ForkJoinWorkerThread to ArrowAssoc[ForkJoinWorkerThread]

Ungrouped