Package org.apache.maven.surefire.junitcore.pc

Class ParallelComputerBuilder

java.lang.Object

org.apache.maven.surefire.junitcore.pc.ParallelComputerBuilder

public final class ParallelComputerBuilder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	ParallelComputerBuilder.PC

Field Summary

Fields

Modifier and Type	Field	Description
private static final ThreadFactory	DAEMON_THREAD_FACTORY
private static final Class<? extends Annotation>	JCIP_NOT_THREAD_SAFE
private final ConsoleLogger	logger
private static final Set<org.junit.runner.Runner>	NULL_SINGLETON
private boolean	optimize
private final Map<Type,Integer>	parallelGroups
private JUnitCoreParameters	parameters
private boolean	runningInTests
(package private) static final int	TOTAL_POOL_SIZE_UNDEFINED
private int	totalPoolSize
private boolean	useSeparatePools

Constructor Summary

Constructors

Constructor	Description
ParallelComputerBuilder(ConsoleLogger logger)	Calling useSeparatePools().
ParallelComputerBuilder(ConsoleLogger logger, JUnitCoreParameters parameters)

Method Summary

Modifier and Type	Method	Description
ParallelComputer	buildComputer()
private static org.junit.runners.Suite	createSuite(Collection<org.junit.runner.Runner> runners)
(package private) boolean	isOptimized()
private static Class<? extends Annotation>	loadNotThreadSafeAnnotations()
(package private) ParallelComputerBuilder	optimize(boolean optimize)
private ParallelComputerBuilder	parallel(int nThreads, Type parallelType)
private ParallelComputerBuilder	parallel(Type parallelType)
(package private) ParallelComputerBuilder	parallelClasses()
(package private) ParallelComputerBuilder	parallelClasses(int nThreads)
(package private) ParallelComputerBuilder	parallelMethods()
(package private) ParallelComputerBuilder	parallelMethods(int nThreads)
(package private) ParallelComputerBuilder	parallelSuites()
(package private) ParallelComputerBuilder	parallelSuites(int nThreads)
private double	parallelTestsTimeoutForcedInSeconds()
private double	parallelTestsTimeoutInSeconds()
private static List<org.junit.runner.Runner>	removeNullRunners(Collection<org.junit.runner.Runner> runners)
(package private) ParallelComputerBuilder	useOnePool()
(package private) ParallelComputerBuilder	useOnePool(int totalPoolSize)
(package private) ParallelComputerBuilder	useSeparatePools()

Methods inherited from class java.lang.Object

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

Field Details

DAEMON_THREAD_FACTORY

private static final ThreadFactory DAEMON_THREAD_FACTORY

JCIP_NOT_THREAD_SAFE

private static final Class<? extends Annotation> JCIP_NOT_THREAD_SAFE

NULL_SINGLETON

private static final Set<org.junit.runner.Runner> NULL_SINGLETON

TOTAL_POOL_SIZE_UNDEFINED

static final int TOTAL_POOL_SIZE_UNDEFINED

See Also:

• Constant Field Values

parallelGroups

private final Map<Type,Integer> parallelGroups

logger

private final ConsoleLogger logger

useSeparatePools

private boolean useSeparatePools

totalPoolSize

private int totalPoolSize

parameters

private JUnitCoreParameters parameters

optimize

private boolean optimize

runningInTests

private boolean runningInTests

Constructor Details

ParallelComputerBuilder

ParallelComputerBuilder(ConsoleLogger logger)

Calling useSeparatePools(). Can be used only in unit tests. Do NOT call this constructor in production.

ParallelComputerBuilder

public ParallelComputerBuilder(ConsoleLogger logger,
 JUnitCoreParameters parameters)

Method Details

buildComputer

public ParallelComputer buildComputer()

useSeparatePools

ParallelComputerBuilder useSeparatePools()

useOnePool

ParallelComputerBuilder useOnePool()

useOnePool

ParallelComputerBuilder useOnePool(int totalPoolSize)

Parameters:

totalPoolSize - Pool size where suites, classes and methods are executed in parallel. If the totalPoolSize is Integer.MAX_VALUE, the pool capacity is not limited.

Throws:

IllegalArgumentException - If totalPoolSize is < 1.

isOptimized

boolean isOptimized()

optimize

ParallelComputerBuilder optimize(boolean optimize)

parallelSuites

ParallelComputerBuilder parallelSuites()

parallelSuites

ParallelComputerBuilder parallelSuites(int nThreads)

parallelClasses

ParallelComputerBuilder parallelClasses()

parallelClasses

ParallelComputerBuilder parallelClasses(int nThreads)

parallelMethods

ParallelComputerBuilder parallelMethods()

parallelMethods

ParallelComputerBuilder parallelMethods(int nThreads)

parallel

private ParallelComputerBuilder parallel(int nThreads,
 Type parallelType)

parallel

private ParallelComputerBuilder parallel(Type parallelType)

parallelTestsTimeoutInSeconds

private double parallelTestsTimeoutInSeconds()

parallelTestsTimeoutForcedInSeconds

private double parallelTestsTimeoutForcedInSeconds()

loadNotThreadSafeAnnotations

private static Class<? extends Annotation> loadNotThreadSafeAnnotations()

createSuite

private static org.junit.runners.Suite createSuite(Collection<org.junit.runner.Runner> runners)
                                            throws org.junit.runners.model.InitializationError

Throws:

org.junit.runners.model.InitializationError

removeNullRunners

private static List<org.junit.runner.Runner> removeNullRunners(Collection<org.junit.runner.Runner> runners)