final class ParallelComputerBuilder.PC extends ParallelComputer
Modifier and Type | Class and Description |
---|---|
private class |
ParallelComputerBuilder.PC.SuiteFilter |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<Type,java.lang.Integer> |
allGroups |
private java.util.Collection<org.junit.runners.ParentRunner> |
classes |
private Scheduler |
master |
private java.util.Collection<org.junit.runners.ParentRunner> |
nestedClasses |
private long |
nestedClassesChildren |
private java.util.Collection<org.junit.runners.ParentRunner> |
nestedSuites |
private java.util.Collection<org.junit.runner.Runner> |
notParallelRunners |
private SingleThreadScheduler |
notThreadSafeTests |
private int |
poolCapacity |
private boolean |
splitPool |
private java.util.Collection<org.junit.runners.ParentRunner> |
suites |
Modifier | Constructor and Description |
---|---|
private |
PC() |
Modifier and Type | Method and Description |
---|---|
private boolean |
canSchedule(org.junit.runner.Runner runner) |
private int |
countChildren(org.junit.runner.Runner runner) |
private int |
countFinalRunners() |
private org.junit.runners.ParentRunner |
createFinalRunner(java.util.List<org.junit.runner.Runner> runners) |
private Scheduler |
createMaster(java.util.concurrent.ExecutorService pool,
int poolSize) |
private java.util.concurrent.ExecutorService |
createPool(int poolSize) |
private Scheduler |
createScheduler(org.junit.runner.Description desc,
java.util.concurrent.ExecutorService pool,
boolean doParallel,
Balancer concurrency) |
private Scheduler |
createScheduler(int poolSize) |
protected ShutdownResult |
describeStopped(boolean shutdownNow) |
private void |
determineThreadCounts(long suites,
long classes,
long methods) |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
getClasses() |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
getNestedClasses() |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
getNestedSuites() |
(package private) java.util.Collection<org.junit.runner.Runner> |
getNotParallelRunners() |
(package private) int |
getPoolCapacity() |
protected org.junit.runner.Runner |
getRunner(org.junit.runners.model.RunnerBuilder builder,
java.lang.Class<?> testClass) |
org.junit.runner.Runner |
getSuite(org.junit.runners.model.RunnerBuilder builder,
java.lang.Class<?>[] cls) |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
getSuites() |
(package private) boolean |
isSplitPool() |
private boolean |
isThreadSafe(org.junit.runner.Runner runner) |
private void |
populateChildrenFromSuites() |
private void |
setSchedulers(java.lang.Iterable<? extends org.junit.runners.ParentRunner> runners,
int poolSize,
java.util.concurrent.ExecutorService commonPool) |
private org.junit.runner.Runner |
setSchedulers(org.junit.runners.ParentRunner suiteSuites,
org.junit.runners.ParentRunner suiteClasses) |
protected boolean |
shutdownThreadPoolsAwaitingKilled() |
private int |
totalPoolSize() |
private <T extends org.junit.runner.Runner> |
wrapRunners(java.util.Collection<T> runners) |
afterRunQuietly, beforeRunQuietly, describeElapsedTimeout
private final SingleThreadScheduler notThreadSafeTests
private final java.util.Collection<org.junit.runners.ParentRunner> suites
private final java.util.Collection<org.junit.runners.ParentRunner> nestedSuites
private final java.util.Collection<org.junit.runners.ParentRunner> classes
private final java.util.Collection<org.junit.runners.ParentRunner> nestedClasses
private final java.util.Collection<org.junit.runner.Runner> notParallelRunners
private int poolCapacity
private boolean splitPool
private final java.util.Map<Type,java.lang.Integer> allGroups
private long nestedClassesChildren
private volatile Scheduler master
java.util.Collection<org.junit.runners.ParentRunner> getSuites()
java.util.Collection<org.junit.runners.ParentRunner> getNestedSuites()
java.util.Collection<org.junit.runners.ParentRunner> getClasses()
java.util.Collection<org.junit.runners.ParentRunner> getNestedClasses()
java.util.Collection<org.junit.runner.Runner> getNotParallelRunners()
int getPoolCapacity()
boolean isSplitPool()
protected ShutdownResult describeStopped(boolean shutdownNow)
describeStopped
in class ParallelComputer
protected boolean shutdownThreadPoolsAwaitingKilled()
shutdownThreadPoolsAwaitingKilled
in class ParallelComputer
public org.junit.runner.Runner getSuite(org.junit.runners.model.RunnerBuilder builder, java.lang.Class<?>[] cls) throws org.junit.runners.model.InitializationError
getSuite
in class org.junit.runner.Computer
org.junit.runners.model.InitializationError
protected org.junit.runner.Runner getRunner(org.junit.runners.model.RunnerBuilder builder, java.lang.Class<?> testClass) throws java.lang.Throwable
getRunner
in class org.junit.runner.Computer
java.lang.Throwable
private void determineThreadCounts(long suites, long classes, long methods) throws TestSetFailedException
TestSetFailedException
private <T extends org.junit.runner.Runner> WrappedRunners wrapRunners(java.util.Collection<T> runners) throws org.junit.runners.model.InitializationError
org.junit.runners.model.InitializationError
private int countChildren(org.junit.runner.Runner runner)
private java.util.concurrent.ExecutorService createPool(int poolSize)
private Scheduler createMaster(java.util.concurrent.ExecutorService pool, int poolSize)
private int countFinalRunners()
private void populateChildrenFromSuites()
private int totalPoolSize()
private org.junit.runner.Runner setSchedulers(org.junit.runners.ParentRunner suiteSuites, org.junit.runners.ParentRunner suiteClasses) throws org.junit.runners.model.InitializationError
org.junit.runners.model.InitializationError
private org.junit.runners.ParentRunner createFinalRunner(java.util.List<org.junit.runner.Runner> runners) throws org.junit.runners.model.InitializationError
org.junit.runners.model.InitializationError
private void setSchedulers(java.lang.Iterable<? extends org.junit.runners.ParentRunner> runners, int poolSize, java.util.concurrent.ExecutorService commonPool)
private Scheduler createScheduler(org.junit.runner.Description desc, java.util.concurrent.ExecutorService pool, boolean doParallel, Balancer concurrency)
private Scheduler createScheduler(int poolSize)
private boolean canSchedule(org.junit.runner.Runner runner)
private boolean isThreadSafe(org.junit.runner.Runner runner)