public static final class ForkJoinExecutorConfigurator.AkkaForkJoinPool extends java.util.concurrent.ForkJoinPool implements LoadMetrics
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
boolean |
atFullThrottle() |
void |
execute(java.lang.Runnable r) |
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
public AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)
public AkkaForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)
public void execute(java.lang.Runnable r)
execute
in interface java.util.concurrent.Executor
execute
in class java.util.concurrent.ForkJoinPool
public boolean atFullThrottle()
atFullThrottle
in interface LoadMetrics