Class ParallelComputer
java.lang.Object
org.junit.runner.Computer
org.apache.maven.surefire.junitcore.pc.ParallelComputer
- Direct Known Subclasses:
ParallelComputerBuilder.PC
public abstract class ParallelComputer
extends org.junit.runner.Computer
ParallelComputer extends JUnit
Computer
and has a shutdown functionality.- Since:
- 2.16
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final ThreadFactory
private final ShutdownStatus
private static final double
private ScheduledExecutorService
private final ShutdownStatus
private final long
private final long
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final boolean
protected final void
private Callable<ShutdownResult>
private Callable<ShutdownResult>
protected abstract ShutdownResult
describeStopped
(boolean shutdownNow) private ScheduledExecutorService
private boolean
private boolean
private static long
minTimeout
(long timeout1, long timeout2) private double
nanosToSeconds
(long nanos) private static void
printShutdownHook
(Collection<String> executedTests, Collection<String> incompleteTests, Future<ShutdownResult> testsBeforeShutdown) private Future<ShutdownResult>
private Future<ShutdownResult>
private static long
secondsToNanos
(double seconds) protected abstract boolean
Methods inherited from class org.junit.runner.Computer
getRunner, getSuite, serial
-
Field Details
-
DAEMON_THREAD_FACTORY
-
NANOS_IN_A_SECOND
private static final double NANOS_IN_A_SECOND- See Also:
-
shutdownStatus
-
forcedShutdownStatus
-
timeoutNanos
private final long timeoutNanos -
timeoutForcedNanos
private final long timeoutForcedNanos -
shutdownScheduler
-
-
Constructor Details
-
ParallelComputer
public ParallelComputer(double timeoutInSeconds, double timeoutForcedInSeconds)
-
-
Method Details
-
describeStopped
-
shutdownThreadPoolsAwaitingKilled
protected abstract boolean shutdownThreadPoolsAwaitingKilled() -
beforeRunQuietly
protected final void beforeRunQuietly() -
afterRunQuietly
protected final boolean afterRunQuietly() -
describeElapsedTimeout
- Throws:
TestSetFailedException
-
scheduleShutdown
-
scheduleForcedShutdown
-
getShutdownScheduler
-
createShutdownTask
-
createForcedShutdownTask
-
nanosToSeconds
private double nanosToSeconds(long nanos) -
hasTimeout
private boolean hasTimeout() -
hasTimeoutForced
private boolean hasTimeoutForced() -
secondsToNanos
private static long secondsToNanos(double seconds) -
minTimeout
private static long minTimeout(long timeout1, long timeout2) -
printShutdownHook
private static void printShutdownHook(Collection<String> executedTests, Collection<String> incompleteTests, Future<ShutdownResult> testsBeforeShutdown) throws ExecutionException, InterruptedException
-