class DefaultParallelExecutionConfiguration extends java.lang.Object implements ParallelExecutionConfiguration
| Modifier and Type | Field and Description |
|---|---|
private int |
corePoolSize |
private int |
keepAliveSeconds |
private int |
maxPoolSize |
private int |
minimumRunnable |
private int |
parallelism |
private java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> |
saturate |
| Constructor and Description |
|---|
DefaultParallelExecutionConfiguration(int parallelism,
int minimumRunnable,
int maxPoolSize,
int corePoolSize,
int keepAliveSeconds,
java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate) |
| Modifier and Type | Method and Description |
|---|---|
int |
getCorePoolSize()
Get the core thread pool size to be used.
|
int |
getKeepAliveSeconds()
Get the number of seconds for which inactive threads should be kept alive
before terminating them and shrinking the thread pool.
|
int |
getMaxPoolSize()
Get the maximum thread pool size to be used.
|
int |
getMinimumRunnable()
Get the minimum number of runnable threads to be used.
|
int |
getParallelism()
Get the parallelism to be used.
|
java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> |
getSaturatePredicate()
Get the saturate predicate to be used for the execution's
ForkJoinPool. |
private final int parallelism
private final int minimumRunnable
private final int maxPoolSize
private final int corePoolSize
private final int keepAliveSeconds
private final java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate
DefaultParallelExecutionConfiguration(int parallelism,
int minimumRunnable,
int maxPoolSize,
int corePoolSize,
int keepAliveSeconds,
java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate)
public int getParallelism()
ParallelExecutionConfigurationgetParallelism in interface ParallelExecutionConfigurationForkJoinPool.getParallelism()public int getMinimumRunnable()
ParallelExecutionConfigurationgetMinimumRunnable in interface ParallelExecutionConfigurationpublic int getMaxPoolSize()
ParallelExecutionConfigurationgetMaxPoolSize in interface ParallelExecutionConfigurationpublic int getCorePoolSize()
ParallelExecutionConfigurationgetCorePoolSize in interface ParallelExecutionConfigurationpublic int getKeepAliveSeconds()
ParallelExecutionConfigurationgetKeepAliveSeconds in interface ParallelExecutionConfigurationpublic java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> getSaturatePredicate()
ParallelExecutionConfigurationForkJoinPool.getSaturatePredicate in interface ParallelExecutionConfigurationForkJoinPool constructor; may be nullForkJoinPool#ForkJoinPool(int, ForkJoinPool.ForkJoinWorkerThreadFactory, Thread.UncaughtExceptionHandler,
boolean, int, int, int, Predicate, long, TimeUnit)