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

Class InvokerStrategy

java.lang.Object

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

org.apache.maven.surefire.junitcore.pc.InvokerStrategy

All Implemented Interfaces:

Destroyable

final class InvokerStrategy
extends SchedulingStrategy

The sequentially executing strategy in private package.

Since:

2.16

See Also:

• SchedulingStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final Queue<Thread>	activeThreads

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InvokerStrategy(ConsoleLogger logger)

Method Summary

Modifier and Type	Method	Description
boolean	destroy()	Calling ThreadPoolExecutor.shutdown() and ThreadPoolExecutor.awaitTermination(long, java.util.concurrent.TimeUnit).
boolean	finished()	Waiting for scheduled tasks to finish.
boolean	hasSharedThreadPool()
void	schedule(Runnable task)	Schedules tasks if SchedulingStrategy.canSchedule().
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, logQuietly, setDefaultShutdownHandler

Methods inherited from class java.lang.Object

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

Field Details

activeThreads

private final Queue<Thread> activeThreads

Constructor Details

InvokerStrategy

protected InvokerStrategy(ConsoleLogger logger)

Method Details

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

hasSharedThreadPool

public boolean hasSharedThreadPool()

Specified by:

hasSharedThreadPool in class SchedulingStrategy

Returns:

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

finished

public boolean finished()
                 throws InterruptedException

Description copied from class: SchedulingStrategy

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

Specified by:

finished in class SchedulingStrategy

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

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