Package akka.dispatch
Class ForkJoinExecutorConfigurator.AkkaForkJoinPool
- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- java.util.concurrent.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 java.util.concurrent.ForkJoinPool implements LoadMetrics
INTERNAL AKKA USAGE ONLY
-
-
Constructor Summary
Constructors Constructor Description AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)
AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
atFullThrottle()
void
execute(java.lang.Runnable r)
-
Methods inherited from class java.util.concurrent.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
-
-
-
-
Constructor Detail
-
AkkaForkJoinPool
public AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)
-
AkkaForkJoinPool
public AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)
-
-
Method Detail
-
atFullThrottle
public boolean atFullThrottle()
- Specified by:
atFullThrottle
in interfaceLoadMetrics
-
execute
public void execute(java.lang.Runnable r)
- Specified by:
execute
in interfacejava.util.concurrent.Executor
- Overrides:
execute
in classjava.util.concurrent.ForkJoinPool
-
-