public final class ParallelComputerBuilder
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
(package private) class |
ParallelComputerBuilder.PC |
Modifier and Type | Field and 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<?> |
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 and Description |
---|
ParallelComputerBuilder(ConsoleStream logger)
Calling
useSeparatePools() . |
ParallelComputerBuilder(ConsoleStream logger,
JUnitCoreParameters parameters) |
Modifier and Type | Method and 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() |
private static final java.util.concurrent.ThreadFactory DAEMON_THREAD_FACTORY
private static final java.lang.Class<? extends java.lang.annotation.Annotation> JCIP_NOT_THREAD_SAFE
private static final java.util.Set<?> NULL_SINGLETON
static final int TOTAL_POOL_SIZE_UNDEFINED
private final java.util.Map<Type,java.lang.Integer> parallelGroups
private final ConsoleStream logger
private boolean useSeparatePools
private int totalPoolSize
private JUnitCoreParameters parameters
private boolean optimize
private boolean runningInTests
ParallelComputerBuilder(ConsoleStream logger)
useSeparatePools()
.
Can be used only in unit tests.
Do NOT call this constructor in production.public ParallelComputerBuilder(ConsoleStream logger, JUnitCoreParameters parameters)
public ParallelComputer buildComputer()
ParallelComputerBuilder useSeparatePools()
ParallelComputerBuilder useOnePool()
ParallelComputerBuilder useOnePool(int totalPoolSize)
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.java.lang.IllegalArgumentException
- If totalPoolSize is < 1.boolean isOptimized()
ParallelComputerBuilder optimize(boolean optimize)
ParallelComputerBuilder parallelSuites()
ParallelComputerBuilder parallelSuites(int nThreads)
ParallelComputerBuilder parallelClasses()
ParallelComputerBuilder parallelClasses(int nThreads)
ParallelComputerBuilder parallelMethods()
ParallelComputerBuilder parallelMethods(int nThreads)
private ParallelComputerBuilder parallel(int nThreads, Type parallelType)
private ParallelComputerBuilder parallel(Type parallelType)
private double parallelTestsTimeoutInSeconds()
private double parallelTestsTimeoutForcedInSeconds()
private static java.lang.Class<? extends java.lang.annotation.Annotation> loadNotThreadSafeAnnotations()
private static org.junit.runners.Suite createSuite(java.util.Collection<org.junit.runner.Runner> runners) throws org.junit.runners.model.InitializationError
org.junit.runners.model.InitializationError
private static java.util.List<org.junit.runner.Runner> removeNullRunners(java.util.Collection<org.junit.runner.Runner> runners)