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

Class AbstractThreadPoolStrategy

java.lang.Object

org.apache.maven.surefire.junitcore.pc.SchedulingStrategy

org.apache.maven.surefire.junitcore.pc.AbstractThreadPoolStrategy

All Implemented Interfaces:

Destroyable

Direct Known Subclasses:

NonSharedThreadPoolStrategy, SharedThreadPoolStrategy

abstract class AbstractThreadPoolStrategy
extends SchedulingStrategy

Abstract parallel scheduling strategy in private package. The remaining abstract methods have to be implemented differently depending if the thread pool is shared with other strategies or not.

Since:

2.16

See Also:

• SchedulingStrategy
• SharedThreadPoolStrategy
• NonSharedThreadPoolStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final Collection<Future<?>>	futureResults
private boolean	isDestroyed
private final ExecutorService	threadPool

Constructor Summary

Constructors

Constructor	Description
AbstractThreadPoolStrategy(ConsoleLogger logger, ExecutorService threadPool)
AbstractThreadPoolStrategy(ConsoleLogger logger, ExecutorService threadPool, Collection<Future<?>> futureResults)

Method Summary

Modifier and Type	Method	Description
boolean	destroy()	Calling ThreadPoolExecutor.shutdown() and ThreadPoolExecutor.awaitTermination(long, java.util.concurrent.TimeUnit).
protected final Collection<Future<?>>	getFutureResults()
protected final ExecutorService	getThreadPool()
void	schedule(Runnable task)	Schedules tasks if SchedulingStrategy.canSchedule().
protected void	setDefaultShutdownHandler(Scheduler.ShutdownHandler handler)
protected boolean	stop()	Stops scheduling new tasks (e.g.
protected boolean	stopNow()	Stops scheduling new tasks and interrupts running tasks (e.g.

Methods inherited from class org.apache.maven.surefire.junitcore.pc.SchedulingStrategy

canSchedule, disable, finished, hasSharedThreadPool, logQuietly

Methods inherited from class java.lang.Object

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

Field Details

threadPool

private final ExecutorService threadPool

futureResults

private final Collection<Future<?>> futureResults

isDestroyed

private volatile boolean isDestroyed

Constructor Details

AbstractThreadPoolStrategy

AbstractThreadPoolStrategy(ConsoleLogger logger,
 ExecutorService threadPool)

AbstractThreadPoolStrategy

AbstractThreadPoolStrategy(ConsoleLogger logger,
 ExecutorService threadPool,
 Collection<Future<?>> futureResults)

Method Details

getThreadPool

protected final ExecutorService getThreadPool()

getFutureResults

protected final Collection<Future<?>> getFutureResults()

schedule

public void schedule(Runnable task)

Description copied from class: SchedulingStrategy

Schedules tasks if SchedulingStrategy.canSchedule().

Specified by:

schedule in class SchedulingStrategy

Parameters:

task - runnable to schedule in a thread pool or invoke

See Also:

• RunnerScheduler.schedule(Runnable)
• Executor.execute(Runnable)

stop

protected boolean stop()

Description copied from class: SchedulingStrategy

Stops scheduling new tasks (e.g. by ExecutorService.shutdown() on a private thread pool which cannot be shared with other strategy).

Specified by:

stop in class SchedulingStrategy

Returns:

true if successfully stopped the scheduler, else false if already stopped (a shared thread pool was shutdown externally).

See Also:

• ExecutorService.shutdown()

stopNow

protected boolean stopNow()

Description copied from class: SchedulingStrategy

Stops scheduling new tasks and interrupts running tasks (e.g. by ExecutorService.shutdownNow() on a private thread pool which cannot be shared with other strategy).
This method calls SchedulingStrategy.stop() by default.

Overrides:

stopNow in class SchedulingStrategy

Returns:

true if successfully stopped the scheduler, else false if already stopped (a shared thread pool was shutdown externally).

See Also:

• ExecutorService.shutdownNow()

setDefaultShutdownHandler

protected void setDefaultShutdownHandler(Scheduler.ShutdownHandler handler)

Overrides:

setDefaultShutdownHandler in class SchedulingStrategy

See Also:

• Scheduler.ShutdownHandler

destroy

public boolean destroy()

Description copied from interface: Destroyable

Calling ThreadPoolExecutor.shutdown() and ThreadPoolExecutor.awaitTermination(long, java.util.concurrent.TimeUnit).

Returns:

true if not interrupted in current thread