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

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

Method Summary

<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

MonitorableThreadFactory.AkkaForkJoinWorkerThread

public MonitorableThreadFactory.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