akka.dispatch

Class MonitorableThreadFactory.AkkaForkJoinWorkerThread

java.lang.Object

java.lang.Thread

java.util.concurrent.ForkJoinWorkerThread

akka.dispatch.MonitorableThreadFactory.AkkaForkJoinWorkerThread

All Implemented Interfaces:

java.lang.Runnable, scala.concurrent.BlockContext

Enclosing class:

MonitorableThreadFactory

public static class MonitorableThreadFactory.AkkaForkJoinWorkerThread
extends java.util.concurrent.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(java.util.concurrent.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 java.util.concurrent.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

Methods inherited from interface scala.concurrent.BlockContext

current, defaultBlockContext, withBlockContext

Constructor Detail

AkkaForkJoinWorkerThread

public AkkaForkJoinWorkerThread(java.util.concurrent.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