org.apache.maven.surefire.junitcore.pc

Class SchedulingStrategy

java.lang.Object

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

public abstract class SchedulingStrategy
extends Object

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

Author:

Tibor Digana (tibor17)

Constructor Summary

Constructors

Constructor and Description
SchedulingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract boolean	canSchedule()
protected abstract boolean	finished() Waiting for scheduled tasks to finish.
protected abstract boolean	hasSharedThreadPool()
protected abstract void	schedule(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

Constructor Detail

SchedulingStrategy

public SchedulingStrategy()

Method Detail

schedule

protected abstract void schedule(Runnable task)

Schedules tasks if canSchedule().

Parameters:

task - runnable to schedule in a thread pool or invoke

Throws:

RejectedExecutionException - if task cannot be scheduled for execution

NullPointerException - if task is null

See Also:

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

finished

protected abstract boolean finished()
                             throws 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:

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

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 abstract boolean canSchedule()

Returns:

true unless stopped or finished.