Class ParallelComputerUtil
- java.lang.Object
-
- org.apache.maven.surefire.junitcore.pc.ParallelComputerUtil
-
final class ParallelComputerUtil extends java.lang.Object
An algorithm which configuresParallelComputer
with allocated thread resources by givenJUnitCoreParameters
. TheAbstractSurefireMojo
has to provide correct combinations of thread-counts and configuration parameterparallel
.- Since:
- 2.16
- See Also:
ParallelComputerBuilder
-
-
Field Summary
Fields Modifier and Type Field Description private static int
availableProcessors
private static java.util.Collection<org.junit.runner.Description>
UNUSED_DESCRIPTIONS
-
Constructor Summary
Constructors Modifier Constructor Description private
ParallelComputerUtil()
-
Method Summary
All Methods Static Methods Concrete Methods 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(java.util.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)
-
-
-
Method Detail
-
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(java.util.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)
-
-