akka.dispatch
Class ForkJoinExecutorConfigurator.AkkaForkJoinPool

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      scala.concurrent.forkjoin.ForkJoinPool
          akka.dispatch.ForkJoinExecutorConfigurator.AkkaForkJoinPool

All Implemented Interfaces:

LoadMetrics, java.util.concurrent.Executor, java.util.concurrent.ExecutorService

Enclosing class:

ForkJoinExecutorConfigurator

public static final class ForkJoinExecutorConfigurator.AkkaForkJoinPool
extends scala.concurrent.forkjoin.ForkJoinPool
implements LoadMetrics

INTERNAL AKKA USAGE ONLY

Nested Class Summary

Nested classes/interfaces inherited from class scala.concurrent.forkjoin.ForkJoinPool

scala.concurrent.forkjoin.ForkJoinPool.ForkJoinWorkerThreadFactory, scala.concurrent.forkjoin.ForkJoinPool.ManagedBlocker

Field Summary

Fields inherited from class scala.concurrent.forkjoin.ForkJoinPool

defaultForkJoinWorkerThreadFactory

Constructor Summary

ForkJoinExecutorConfigurator.AkkaForkJoinPool(int parallelism, scala.concurrent.forkjoin.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)

ForkJoinExecutorConfigurator.AkkaForkJoinPool(int parallelism, scala.concurrent.forkjoin.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)

Method Summary

boolean	atFullThrottle()
void	execute(java.lang.Runnable r)

Methods inherited from class scala.concurrent.forkjoin.ForkJoinPool

awaitQuiescence, awaitTermination, commonPool, drainTasksTo, execute, getActiveThreadCount, getAsyncMode, getCommonPoolParallelism, getFactory, getParallelism, getPoolSize, getQueuedSubmissionCount, getQueuedTaskCount, getRunningThreadCount, getStealCount, getUncaughtExceptionHandler, hasQueuedSubmissions, invoke, invokeAll, isQuiescent, isShutdown, isTerminated, isTerminating, managedBlock, newTaskFor, newTaskFor, pollSubmission, shutdown, shutdownNow, submit, submit, submit, submit, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkJoinExecutorConfigurator.AkkaForkJoinPool

public ForkJoinExecutorConfigurator.AkkaForkJoinPool(int parallelism,
                                                     scala.concurrent.forkjoin.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory,
                                                     java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler,
                                                     boolean asyncMode)

ForkJoinExecutorConfigurator.AkkaForkJoinPool

public ForkJoinExecutorConfigurator.AkkaForkJoinPool(int parallelism,
                                                     scala.concurrent.forkjoin.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory,
                                                     java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)

Method Detail

execute

public void execute(java.lang.Runnable r)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute in class scala.concurrent.forkjoin.ForkJoinPool

atFullThrottle

public boolean atFullThrottle()

Specified by:

atFullThrottle in interface LoadMetrics