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)
CallinguseSeparatePools()
.ParallelComputerBuilder(ConsoleStream logger, JUnitCoreParameters parameters)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods 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()
-
-
-
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)
CallinguseSeparatePools()
. 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 isInteger.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)
-
-