Package org.apache.maven.surefire.junitcore.pc

Class ParallelComputerUtil

java.lang.Object

org.apache.maven.surefire.junitcore.pc.ParallelComputerUtil

final class ParallelComputerUtil
extends Object

An algorithm which configures ParallelComputer with allocated thread resources by given JUnitCoreParameters. The AbstractSurefireMojo has to provide correct combinations of thread-counts and configuration parameter parallel.

Since:

2.16

See Also:

• ParallelComputerBuilder

Field Summary

Fields

Modifier and Type	Field	Description
private static int	availableProcessors
private static final Collection<org.junit.runner.Description>	UNUSED_DESCRIPTIONS

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ParallelComputerUtil()

Method Summary

Modifier and Type	Method	Description
private static void	adjustLeaf(JUnitCoreParameters params, Concurrency concurrency)
private static void	adjustPrecisionInLeaf(JUnitCoreParameters params, Concurrency concurrency)
private static Concurrency	concurrencyForUnlimitedThreads(JUnitCoreParameters params)
private static Concurrency	concurrencyFromAllThreadCounts(JUnitCoreParameters params)
private static Concurrency	concurrencyFromAllThreadCountsButUnspecifiedLeafCount(JUnitCoreParameters params, RunnerCounter counts)
private static Concurrency	concurrencyFromThreadCounts(JUnitCoreParameters params)
private static int	countParallelEntities(JUnitCoreParameters params)
private static Concurrency	estimateConcurrency(JUnitCoreParameters params, RunnerCounter counts)
private static boolean	hasThreadCount(JUnitCoreParameters jUnitCoreParameters)
private static boolean	hasThreadCounts(JUnitCoreParameters jUnitCoreParameters)
private static boolean	isLeafUnspecified(JUnitCoreParameters params)
(package private) static boolean	isUnusedDescription(org.junit.runner.Description examined)
private static int	minClasses(int threads, RunnerCounter counts)
private static int	minMethods(int threads, RunnerCounter counts)
private static int	minSuites(int threads, RunnerCounter counts)
private static int	multiplyByCoreCount(JUnitCoreParameters jUnitCoreParameters, double threadsPerCore)
(package private) static void	overrideAvailableProcessors(int availableProcessors)
(package private) static void	removeUnusedDescriptions(Collection<org.junit.runner.Description> examined)
(package private) static Concurrency	resolveConcurrency(JUnitCoreParameters params, RunnerCounter counts)
(package private) static void	setDefaultAvailableProcessors()
private static void	setLeafInfinite(JUnitCoreParameters params, Concurrency concurrency)
private static double	sumThreadCounts(Concurrency concurrency)
private static int	threadCountClasses(JUnitCoreParameters jUnitCoreParameters)
private static int	threadCountMethods(JUnitCoreParameters jUnitCoreParameters)
private static int	threadCountSuites(JUnitCoreParameters jUnitCoreParameters)
private static int	toNonNegative(double num)
private static int	toNonNegative(long num)

Methods inherited from class java.lang.Object

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

Field Details

UNUSED_DESCRIPTIONS

private static final Collection<org.junit.runner.Description> UNUSED_DESCRIPTIONS

availableProcessors

private static int availableProcessors

Constructor Details

ParallelComputerUtil

private ParallelComputerUtil()

Method Details

overrideAvailableProcessors

static void overrideAvailableProcessors(int availableProcessors)

setDefaultAvailableProcessors

static void setDefaultAvailableProcessors()

resolveConcurrency

static Concurrency resolveConcurrency(JUnitCoreParameters params,
 RunnerCounter counts)
                               throws TestSetFailedException

Throws:

TestSetFailedException

isUnusedDescription

static boolean isUnusedDescription(org.junit.runner.Description examined)

removeUnusedDescriptions

static void removeUnusedDescriptions(Collection<org.junit.runner.Description> examined)

concurrencyForUnlimitedThreads

private static Concurrency concurrencyForUnlimitedThreads(JUnitCoreParameters params)

estimateConcurrency

private static Concurrency estimateConcurrency(JUnitCoreParameters params,
 RunnerCounter counts)

concurrencyFromAllThreadCountsButUnspecifiedLeafCount

private static Concurrency concurrencyFromAllThreadCountsButUnspecifiedLeafCount(JUnitCoreParameters params,
 RunnerCounter counts)

concurrencyFromAllThreadCounts

private static Concurrency concurrencyFromAllThreadCounts(JUnitCoreParameters params)

concurrencyFromThreadCounts

private static Concurrency concurrencyFromThreadCounts(JUnitCoreParameters params)

countParallelEntities

private static int countParallelEntities(JUnitCoreParameters params)

adjustPrecisionInLeaf

private static void adjustPrecisionInLeaf(JUnitCoreParameters params,
 Concurrency concurrency)

adjustLeaf

private static void adjustLeaf(JUnitCoreParameters params,
 Concurrency concurrency)

setLeafInfinite

private static void setLeafInfinite(JUnitCoreParameters params,
 Concurrency concurrency)

isLeafUnspecified

private static boolean isLeafUnspecified(JUnitCoreParameters params)

sumThreadCounts

private static double sumThreadCounts(Concurrency concurrency)

hasThreadCounts

private static boolean hasThreadCounts(JUnitCoreParameters jUnitCoreParameters)

hasThreadCount

private static boolean hasThreadCount(JUnitCoreParameters jUnitCoreParameters)

threadCountMethods

private static int threadCountMethods(JUnitCoreParameters jUnitCoreParameters)

threadCountClasses

private static int threadCountClasses(JUnitCoreParameters jUnitCoreParameters)

threadCountSuites

private static int threadCountSuites(JUnitCoreParameters jUnitCoreParameters)

multiplyByCoreCount

private static int multiplyByCoreCount(JUnitCoreParameters jUnitCoreParameters,
 double threadsPerCore)

minSuites

private static int minSuites(int threads,
 RunnerCounter counts)

minClasses

private static int minClasses(int threads,
 RunnerCounter counts)

minMethods

private static int minMethods(int threads,
 RunnerCounter counts)

toNonNegative

private static int toNonNegative(long num)

toNonNegative

private static int toNonNegative(double num)