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

Class ParallelComputerBuilder

java.lang.Object

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

public final class ParallelComputerBuilder
extends java.lang.Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ParallelComputer	buildComputer()
private static org.junit.runners.Suite	createSuite(java.util.Collection<org.junit.runner.Runner> runners)
(package private) boolean	isOptimized()
private static java.lang.Class<? extends java.lang.annotation.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 java.util.List<org.junit.runner.Runner>	removeNullRunners(java.util.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 Detail

DAEMON_THREAD_FACTORY

private static final java.util.concurrent.ThreadFactory DAEMON_THREAD_FACTORY

JCIP_NOT_THREAD_SAFE

private static final java.lang.Class<? extends java.lang.annotation.Annotation> JCIP_NOT_THREAD_SAFE

NULL_SINGLETON

private static final java.util.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 java.util.Map<Type,java.lang.Integer> parallelGroups

logger

private final ConsoleStream logger

useSeparatePools

private boolean useSeparatePools

totalPoolSize

private int totalPoolSize

parameters

private JUnitCoreParameters parameters

optimize

private boolean optimize

runningInTests

private boolean runningInTests

Constructor Detail

ParallelComputerBuilder

ParallelComputerBuilder(ConsoleStream logger)

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

ParallelComputerBuilder

public ParallelComputerBuilder(ConsoleStream logger,
                               JUnitCoreParameters parameters)

Method Detail

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:

java.lang.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 java.lang.Class<? extends java.lang.annotation.Annotation> loadNotThreadSafeAnnotations()

createSuite

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

Throws:

org.junit.runners.model.InitializationError

removeNullRunners

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