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

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:

• ParallelComputerBuilder

Field Summary

Fields

Modifier and Type	Field	Description
private static final ThreadFactory	DAEMON_THREAD_FACTORY
private final ShutdownStatus	forcedShutdownStatus
private static final double	NANOS_IN_A_SECOND
private ScheduledExecutorService	shutdownScheduler
private final ShutdownStatus	shutdownStatus
private final long	timeoutForcedNanos
private final long	timeoutNanos

Constructor Summary

Constructors

Constructor	Description
ParallelComputer(double timeoutInSeconds, double timeoutForcedInSeconds)

Method Summary

Modifier and Type	Method	Description
protected final boolean	afterRunQuietly()
protected final void	beforeRunQuietly()
private Callable<ShutdownResult>	createForcedShutdownTask()
private Callable<ShutdownResult>	createShutdownTask()
String	describeElapsedTimeout()
protected abstract ShutdownResult	describeStopped(boolean shutdownNow)
private ScheduledExecutorService	getShutdownScheduler()
private boolean	hasTimeout()
private boolean	hasTimeoutForced()
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>	scheduleForcedShutdown()
private Future<ShutdownResult>	scheduleShutdown()
private static long	secondsToNanos(double seconds)
protected abstract boolean	shutdownThreadPoolsAwaitingKilled()

Methods inherited from class org.junit.runner.Computer

getRunner, getSuite, serial

Methods inherited from class java.lang.Object

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

Field Details

DAEMON_THREAD_FACTORY

private static final ThreadFactory DAEMON_THREAD_FACTORY

NANOS_IN_A_SECOND

private static final double NANOS_IN_A_SECOND

See Also:

• Constant Field Values

shutdownStatus

private final ShutdownStatus shutdownStatus

forcedShutdownStatus

private final ShutdownStatus forcedShutdownStatus

timeoutNanos

private final long timeoutNanos

timeoutForcedNanos

private final long timeoutForcedNanos

shutdownScheduler

private ScheduledExecutorService shutdownScheduler

Constructor Details

ParallelComputer

public ParallelComputer(double timeoutInSeconds,
 double timeoutForcedInSeconds)

Method Details

describeStopped

protected abstract ShutdownResult describeStopped(boolean shutdownNow)

shutdownThreadPoolsAwaitingKilled

protected abstract boolean shutdownThreadPoolsAwaitingKilled()

beforeRunQuietly

protected final void beforeRunQuietly()

afterRunQuietly

protected final boolean afterRunQuietly()

describeElapsedTimeout

public String describeElapsedTimeout()
                              throws TestSetFailedException

Throws:

TestSetFailedException

scheduleShutdown

private Future<ShutdownResult> scheduleShutdown()

scheduleForcedShutdown

private Future<ShutdownResult> scheduleForcedShutdown()

getShutdownScheduler

private ScheduledExecutorService getShutdownScheduler()

createShutdownTask

private Callable<ShutdownResult> createShutdownTask()

createForcedShutdownTask

private Callable<ShutdownResult> 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

Throws:

ExecutionException

InterruptedException