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 |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
classes |
private Scheduler |
master |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
nestedClasses |
private long |
nestedClassesChildren |
(package private) java.util.Collection<org.junit.runners.ParentRunner> |
nestedSuites |
(package private) java.util.Collection<org.junit.runner.Runner> |
notParallelRunners |
private SingleThreadScheduler |
notThreadSafeTests |
(package private) int |
poolCapacity |
(package private) boolean |
splitPool |
(package 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) |
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) |
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) |
(package private) 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
final java.util.Collection<org.junit.runners.ParentRunner> suites
final java.util.Collection<org.junit.runners.ParentRunner> nestedSuites
final java.util.Collection<org.junit.runners.ParentRunner> classes
final java.util.Collection<org.junit.runners.ParentRunner> nestedClasses
final java.util.Collection<org.junit.runner.Runner> notParallelRunners
int poolCapacity
boolean splitPool
private final java.util.Map<Type,java.lang.Integer> allGroups
private long nestedClassesChildren
private volatile Scheduler master
protected ShutdownResult describeStopped(boolean shutdownNow)
describeStopped
in class ParallelComputer
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)