Module org.junit.platform.engine

Package org.junit.platform.engine.support.hierarchical

Class DefaultParallelExecutionConfiguration

java.lang.Object

org.junit.platform.engine.support.hierarchical.DefaultParallelExecutionConfiguration

All Implemented Interfaces:

ParallelExecutionConfiguration

class DefaultParallelExecutionConfiguration
extends Object
implements ParallelExecutionConfiguration

Since:

1.3

Field Summary

Fields

Modifier and Type	Field	Description
private final int	corePoolSize
private final int	keepAliveSeconds
private final int	maxPoolSize
private final int	minimumRunnable
private final int	parallelism
private final Predicate<? super ForkJoinPool>	saturate

Constructor Summary

Constructors

Constructor	Description
DefaultParallelExecutionConfiguration(int parallelism, int minimumRunnable, int maxPoolSize, int corePoolSize, int keepAliveSeconds, Predicate<? super ForkJoinPool> saturate)

Method Summary

Modifier and Type	Method	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.
Predicate<? super ForkJoinPool>	getSaturatePredicate()	Get the saturate predicate to be used for the execution's ForkJoinPool.

Methods inherited from class java.lang.Object

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

Field Details

parallelism

private final int parallelism

minimumRunnable

private final int minimumRunnable

maxPoolSize

private final int maxPoolSize

corePoolSize

private final int corePoolSize

keepAliveSeconds

private final int keepAliveSeconds

saturate

private final Predicate<? super ForkJoinPool> saturate

Constructor Details

DefaultParallelExecutionConfiguration

DefaultParallelExecutionConfiguration(int parallelism,
 int minimumRunnable,
 int maxPoolSize,
 int corePoolSize,
 int keepAliveSeconds,
 Predicate<? super ForkJoinPool> saturate)

Method Details

getParallelism

public int getParallelism()

Description copied from interface: ParallelExecutionConfiguration

Get the parallelism to be used.

Specified by:

getParallelism in interface ParallelExecutionConfiguration

See Also:

• ForkJoinPool.getParallelism()

getMinimumRunnable

public int getMinimumRunnable()

Description copied from interface: ParallelExecutionConfiguration

Get the minimum number of runnable threads to be used.

Specified by:

getMinimumRunnable in interface ParallelExecutionConfiguration

getMaxPoolSize

public int getMaxPoolSize()

Description copied from interface: ParallelExecutionConfiguration

Get the maximum thread pool size to be used.

Specified by:

getMaxPoolSize in interface ParallelExecutionConfiguration

getCorePoolSize

public int getCorePoolSize()

Description copied from interface: ParallelExecutionConfiguration

Get the core thread pool size to be used.

Specified by:

getCorePoolSize in interface ParallelExecutionConfiguration

getKeepAliveSeconds

public int getKeepAliveSeconds()

Description copied from interface: ParallelExecutionConfiguration

Get the number of seconds for which inactive threads should be kept alive before terminating them and shrinking the thread pool.

Specified by:

getKeepAliveSeconds in interface ParallelExecutionConfiguration

getSaturatePredicate

public Predicate<? super ForkJoinPool> getSaturatePredicate()

Description copied from interface: ParallelExecutionConfiguration

Get the saturate predicate to be used for the execution's ForkJoinPool.

Specified by:

getSaturatePredicate in interface ParallelExecutionConfiguration

Returns:

the saturate predicate to be passed to the ForkJoinPool constructor; may be null

See Also:

• ForkJoinPool(int, ForkJoinPool.ForkJoinWorkerThreadFactory, Thread.UncaughtExceptionHandler, boolean, int, int, int, Predicate, long, TimeUnit)