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:

Executor, ExecutorService, LoadMetrics

Enclosing class:

ForkJoinExecutorConfigurator

public static final class ForkJoinExecutorConfigurator.PekkoForkJoinPool
extends ForkJoinPool
implements LoadMetrics

INTERNAL PEKKO USAGE ONLY

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ForkJoinPool

ForkJoinPool.ForkJoinWorkerThreadFactory, ForkJoinPool.ManagedBlocker

Field Summary

Fields inherited from class java.util.concurrent.ForkJoinPool

defaultForkJoinWorkerThreadFactory

Constructor Summary

Constructors

Constructor	Description
PekkoForkJoinPool(int parallelism, ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int maximumPoolSize, Thread.UncaughtExceptionHandler unhandledExceptionHandler, boolean asyncMode)

Method Summary

Modifier and Type	Method	Description
boolean	atFullThrottle()
void	execute(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, invokeAll, invokeAny, invokeAny, isQuiescent, isShutdown, isTerminated, isTerminating, managedBlock, newTaskFor, newTaskFor, pollSubmission, shutdown, shutdownNow, submit, submit, submit, submit, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

PekkoForkJoinPool

public PekkoForkJoinPool(int parallelism,
 ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory,
 int maximumPoolSize,
 Thread.UncaughtExceptionHandler unhandledExceptionHandler,
 boolean asyncMode)

Method Details

atFullThrottle

public boolean atFullThrottle()

Specified by:

atFullThrottle in interface LoadMetrics

execute

public void execute(Runnable r)

Specified by:

execute in interface Executor

Overrides:

execute in class ForkJoinPool