Package akka.dispatch

Class ForkJoinExecutorConfigurator.AkkaForkJoinPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

akka.dispatch.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 ForkJoinPool
implements LoadMetrics

Nested Class Summary

Nested classes/interfaces inherited from class akka.dispatch.forkjoin.ForkJoinPool

ForkJoinPool.ForkJoinWorkerThreadFactory, ForkJoinPool.ManagedBlocker

Field Summary

Fields inherited from class akka.dispatch.forkjoin.ForkJoinPool

defaultForkJoinWorkerThreadFactory

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	atFullThrottle()
void	execute(java.lang.Runnable r)

Methods inherited from class akka.dispatch.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,
                        ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory,
                        java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler,
                        boolean asyncMode)

AkkaForkJoinPool

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

Method Detail

atFullThrottle

public boolean atFullThrottle()

Specified by:

atFullThrottle in interface LoadMetrics

execute

public void execute(java.lang.Runnable r)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute in class ForkJoinPool