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

Constructors

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

Method Summary

Modifier and Type	Method and Description
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

AkkaForkJoinPool

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

AkkaForkJoinPool

public 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