Package org.apache.pekko.dispatch
Class ForkJoinExecutorConfigurator.ForkJoinExecutorServiceFactory
java.lang.Object
org.apache.pekko.dispatch.ForkJoinExecutorConfigurator.ForkJoinExecutorServiceFactory
- All Implemented Interfaces:
ExecutorServiceFactory
- Enclosing class:
- ForkJoinExecutorConfigurator
public class ForkJoinExecutorConfigurator.ForkJoinExecutorServiceFactory
extends Object
implements ExecutorServiceFactory
-
Constructor Summary
ConstructorsConstructorDescriptionForkJoinExecutorServiceFactory(String id, ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode, int maxPoolSize) ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism) ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode) ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode, int maxPoolSize) -
Method Summary
-
Constructor Details
-
ForkJoinExecutorServiceFactory
public ForkJoinExecutorServiceFactory(String id, ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode, int maxPoolSize) -
ForkJoinExecutorServiceFactory
public ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode, int maxPoolSize) -
ForkJoinExecutorServiceFactory
public ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism, boolean asyncMode) -
ForkJoinExecutorServiceFactory
public ForkJoinExecutorServiceFactory(ForkJoinPool.ForkJoinWorkerThreadFactory threadFactory, int parallelism)
-
-
Method Details
-
asyncMode
public boolean asyncMode() -
createExecutorService
- Specified by:
createExecutorServicein interfaceExecutorServiceFactory
-
id
-
maxPoolSize
public int maxPoolSize() -
parallelism
public int parallelism() -
threadFactory
-