org.apache.maven.surefire.junitcore.pc

Class ParallelComputerBuilder.PC

java.lang.Object

org.junit.runner.Computer

org.apache.maven.surefire.junitcore.pc.ParallelComputer

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

Enclosing class:

ParallelComputerBuilder

final class ParallelComputerBuilder.PC
extends ParallelComputer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ParallelComputerBuilder.PC.SuiteFilter

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	PC()

Method Summary

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> WrappedRunners	wrapRunners(java.util.Collection<T> runners)

Methods inherited from class org.apache.maven.surefire.junitcore.pc.ParallelComputer

afterRunQuietly, beforeRunQuietly, describeElapsedTimeout

Methods inherited from class org.junit.runner.Computer

serial

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

notThreadSafeTests

private final SingleThreadScheduler notThreadSafeTests

suites

final java.util.Collection<org.junit.runners.ParentRunner> suites

nestedSuites

final java.util.Collection<org.junit.runners.ParentRunner> nestedSuites

classes

final java.util.Collection<org.junit.runners.ParentRunner> classes

nestedClasses

final java.util.Collection<org.junit.runners.ParentRunner> nestedClasses

notParallelRunners

final java.util.Collection<org.junit.runner.Runner> notParallelRunners

poolCapacity

int poolCapacity

splitPool

boolean splitPool

allGroups

private final java.util.Map<Type,java.lang.Integer> allGroups

nestedClassesChildren

private long nestedClassesChildren

master

private volatile Scheduler master

Constructor Detail

PC

private PC()

Method Detail

describeStopped

protected ShutdownResult describeStopped(boolean shutdownNow)

Specified by:

describeStopped in class ParallelComputer

shutdownThreadPoolsAwaitingKilled

boolean shutdownThreadPoolsAwaitingKilled()

Specified by:

shutdownThreadPoolsAwaitingKilled in class ParallelComputer

getSuite

public org.junit.runner.Runner getSuite(org.junit.runners.model.RunnerBuilder builder,
                                        java.lang.Class<?>[] cls)
                                 throws org.junit.runners.model.InitializationError

Overrides:

getSuite in class org.junit.runner.Computer

Throws:

org.junit.runners.model.InitializationError

getRunner

protected org.junit.runner.Runner getRunner(org.junit.runners.model.RunnerBuilder builder,
                                            java.lang.Class<?> testClass)
                                     throws java.lang.Throwable

Overrides:

getRunner in class org.junit.runner.Computer

Throws:

java.lang.Throwable

determineThreadCounts

private void determineThreadCounts(long suites,
                                   long classes,
                                   long methods)
                            throws TestSetFailedException

Throws:

TestSetFailedException

wrapRunners

private <T extends org.junit.runner.Runner> WrappedRunners wrapRunners(java.util.Collection<T> runners)
                                                                throws org.junit.runners.model.InitializationError

Throws:

org.junit.runners.model.InitializationError

countChildren

private int countChildren(org.junit.runner.Runner runner)

createPool

private java.util.concurrent.ExecutorService createPool(int poolSize)

createMaster

private Scheduler createMaster(java.util.concurrent.ExecutorService pool,
                               int poolSize)

countFinalRunners

private int countFinalRunners()

populateChildrenFromSuites

private void populateChildrenFromSuites()

totalPoolSize

private int totalPoolSize()

setSchedulers

private org.junit.runner.Runner setSchedulers(org.junit.runners.ParentRunner suiteSuites,
                                              org.junit.runners.ParentRunner suiteClasses)
                                       throws org.junit.runners.model.InitializationError

Throws:

org.junit.runners.model.InitializationError

createFinalRunner

private org.junit.runners.ParentRunner createFinalRunner(java.util.List<org.junit.runner.Runner> runners)
                                                  throws org.junit.runners.model.InitializationError

Throws:

org.junit.runners.model.InitializationError

setSchedulers

private void setSchedulers(java.lang.Iterable<? extends org.junit.runners.ParentRunner> runners,
                           int poolSize,
                           java.util.concurrent.ExecutorService commonPool)

createScheduler

private Scheduler createScheduler(org.junit.runner.Description desc,
                                  java.util.concurrent.ExecutorService pool,
                                  boolean doParallel,
                                  Balancer concurrency)

createScheduler

private Scheduler createScheduler(int poolSize)

canSchedule

private boolean canSchedule(org.junit.runner.Runner runner)

isThreadSafe

private boolean isThreadSafe(org.junit.runner.Runner runner)