akka.dispatch

Class MonitorableThreadFactory.AkkaForkJoinWorkerThread

java.lang.Object

java.lang.Thread

scala.concurrent.forkjoin.ForkJoinWorkerThread

akka.dispatch.MonitorableThreadFactory.AkkaForkJoinWorkerThread

All Implemented Interfaces:

java.lang.Runnable, scala.concurrent.BlockContext

Enclosing class:

MonitorableThreadFactory

public static class MonitorableThreadFactory.AkkaForkJoinWorkerThread
extends scala.concurrent.forkjoin.ForkJoinWorkerThread
implements scala.concurrent.BlockContext

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface scala.concurrent.BlockContext

scala.concurrent.BlockContext.DefaultBlockContext$

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AkkaForkJoinWorkerThread(scala.concurrent.forkjoin.ForkJoinPool _pool)

Method Summary

Modifier and Type	Method and Description
<T> T	blockOn(scala.Function0<T> thunk, scala.concurrent.CanAwait permission)

Methods inherited from class scala.concurrent.forkjoin.ForkJoinWorkerThread

getPool, getPoolIndex, onStart, onTermination, run

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AkkaForkJoinWorkerThread

public AkkaForkJoinWorkerThread(scala.concurrent.forkjoin.ForkJoinPool _pool)

Method Detail

blockOn

public <T> T blockOn(scala.Function0<T> thunk,
                     scala.concurrent.CanAwait permission)

Specified by:

blockOn in interface scala.concurrent.BlockContext