Package org.apache.pekko.dispatch
Class ForkJoinExecutorConfigurator.PekkoForkJoinPool
- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- java.util.concurrent.ForkJoinPool
-
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator.PekkoForkJoinPool
-
- All Implemented Interfaces:
java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
,LoadMetrics
- Enclosing class:
- ForkJoinExecutorConfigurator
public static final class ForkJoinExecutorConfigurator.PekkoForkJoinPool extends java.util.concurrent.ForkJoinPool implements LoadMetrics
INTERNAL PEKKO USAGE ONLY
-
-
Constructor Summary
Constructors Constructor Description PekkoForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler)
PekkoForkJoinPool(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
-
PekkoForkJoinPool
public PekkoForkJoinPool(int parallelism, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, java.lang.Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)
-
PekkoForkJoinPool
public PekkoForkJoinPool(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
-
-