final class ParallelComputerUtil
extends java.lang.Object
ParallelComputer
with allocated thread resources by given
JUnitCoreParameters
.
The AbstractSurefireMojo
has to provide correct combinations of thread-counts and
configuration parameter parallel
.ParallelComputerBuilder
Modifier and Type | Field and Description |
---|---|
private static int |
availableProcessors |
private static java.util.Collection<org.junit.runner.Description> |
UNUSED_DESCRIPTIONS |
Modifier | Constructor and Description |
---|---|
private |
ParallelComputerUtil() |
Modifier and Type | Method and 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) |
private static final java.util.Collection<org.junit.runner.Description> UNUSED_DESCRIPTIONS
private static int availableProcessors
static void overrideAvailableProcessors(int availableProcessors)
static void setDefaultAvailableProcessors()
static Concurrency resolveConcurrency(JUnitCoreParameters params, RunnerCounter counts) throws TestSetFailedException
TestSetFailedException
static boolean isUnusedDescription(org.junit.runner.Description examined)
static void removeUnusedDescriptions(java.util.Collection<org.junit.runner.Description> examined)
private static Concurrency concurrencyForUnlimitedThreads(JUnitCoreParameters params)
private static Concurrency estimateConcurrency(JUnitCoreParameters params, RunnerCounter counts)
private static Concurrency concurrencyFromAllThreadCountsButUnspecifiedLeafCount(JUnitCoreParameters params, RunnerCounter counts)
private static Concurrency concurrencyFromAllThreadCounts(JUnitCoreParameters params)
private static Concurrency concurrencyFromThreadCounts(JUnitCoreParameters params)
private static int countParallelEntities(JUnitCoreParameters params)
private static void adjustPrecisionInLeaf(JUnitCoreParameters params, Concurrency concurrency)
private static void adjustLeaf(JUnitCoreParameters params, Concurrency concurrency)
private static void setLeafInfinite(JUnitCoreParameters params, Concurrency concurrency)
private static boolean isLeafUnspecified(JUnitCoreParameters params)
private static double sumThreadCounts(Concurrency concurrency)
private static boolean hasThreadCounts(JUnitCoreParameters jUnitCoreParameters)
private static boolean hasThreadCount(JUnitCoreParameters jUnitCoreParameters)
private static int threadCountMethods(JUnitCoreParameters jUnitCoreParameters)
private static int threadCountClasses(JUnitCoreParameters jUnitCoreParameters)
private static int threadCountSuites(JUnitCoreParameters jUnitCoreParameters)
private static int multiplyByCoreCount(JUnitCoreParameters jUnitCoreParameters, double threadsPerCore)
private static int minSuites(int threads, RunnerCounter counts)
private static int minClasses(int threads, RunnerCounter counts)
private static int minMethods(int threads, RunnerCounter counts)
private static int toNonNegative(long num)
private static int toNonNegative(double num)