org.apache.maven.surefire.junitcore.pc

Class SchedulingStrategy

java.lang.Object

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

All Implemented Interfaces:

Destroyable

Direct Known Subclasses:

AbstractThreadPoolStrategy, InvokerStrategy

public abstract class SchedulingStrategy
extends java.lang.Object
implements Destroyable

Specifies the strategy of scheduling whether sequential, or parallel. The strategy may use a thread pool shared with other strategies.

One instance of strategy can be used just by one Scheduler.

The strategy is scheduling tasks in schedule(Runnable) and awaiting them completed in finished(). Both methods should be used in one thread.

Since:

2.16

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	canSchedule
private ConsoleLogger	logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SchedulingStrategy(ConsoleLogger logger)

Method Summary

Modifier and Type	Method and Description
protected boolean	canSchedule()
protected boolean	disable() Persistently disables this strategy.
protected abstract boolean	finished() Waiting for scheduled tasks to finish.
protected abstract boolean	hasSharedThreadPool()
protected void	logQuietly(java.lang.Throwable t)
protected abstract void	schedule(java.lang.Runnable task) Schedules tasks if canSchedule().
protected void	setDefaultShutdownHandler(Scheduler.ShutdownHandler handler)
protected abstract 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 java.lang.Object

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

Methods inherited from interface org.apache.maven.surefire.junitcore.pc.Destroyable

destroy

Field Detail

canSchedule

private final java.util.concurrent.atomic.AtomicBoolean canSchedule

logger

private final ConsoleLogger logger

Constructor Detail

SchedulingStrategy

protected SchedulingStrategy(ConsoleLogger logger)

Method Detail

schedule

protected abstract void schedule(java.lang.Runnable task)

Schedules tasks if canSchedule().

Parameters:

task - runnable to schedule in a thread pool or invoke

Throws:

java.util.concurrent.RejectedExecutionException - if task cannot be scheduled for execution

java.lang.NullPointerException - if task is null

See Also:

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

finished

protected abstract boolean finished()
                             throws java.lang.InterruptedException

Waiting for scheduled tasks to finish. New tasks will not be scheduled by calling this method.

Returns:

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

Throws:

java.lang.InterruptedException - if interrupted while waiting for scheduled tasks to finish

See Also:

RunnerScheduler.finished()

stop

protected abstract boolean stop()

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

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()

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 stop() by default.

Returns:

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

See Also:

ExecutorService.shutdownNow()

disable

protected boolean disable()

Persistently disables this strategy. Atomically ignores Balancer to acquire a new permit.

The method canSchedule() atomically returns false.

Returns:

true if canSchedule() has return true on the beginning of this method call.

setDefaultShutdownHandler

protected void setDefaultShutdownHandler(Scheduler.ShutdownHandler handler)

hasSharedThreadPool

protected abstract boolean hasSharedThreadPool()

Returns:

true if a thread pool associated with this strategy can be shared with other strategies.

canSchedule

protected boolean canSchedule()

Returns:

true unless stopped, finished or disabled.

logQuietly

protected void logQuietly(java.lang.Throwable t)