Class DelegatingScheduler

java.lang.Object

dev.failsafe.internal.util.DelegatingScheduler

All Implemented Interfaces:

Scheduler

public final class DelegatingScheduler
extends Object
implements Scheduler

A Scheduler implementation that schedules delays on an internal, common ScheduledExecutorService and executes tasks on either a provided ExecutorService, ForkJoinPool.commonPool(), or an internal ForkJoinPool instance. If no ExecutorService is supplied, the ForkJoinPool.commonPool() will be used, unless the common pool's parallelism is 1, then an internal ForkJoinPool with parallelism of 2 will be created and used.

Supports cancellation and interruption of ForkJoinPool tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	DelegatingScheduler.DelayerThreadFactory
(package private) static final class	DelegatingScheduler.ScheduledCompletableFuture<V>

Field Summary

Fields

Modifier and Type	Field	Description
private static ScheduledThreadPoolExecutor	DELAYER
private final ExecutorService	executorService
private static ForkJoinPool	FORK_JOIN_POOL
static final DelegatingScheduler	INSTANCE

Fields inherited from interface Scheduler

DEFAULT

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DelegatingScheduler()
	DelegatingScheduler(ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
private static ScheduledExecutorService	delayer()
private ExecutorService	executorService()
ScheduledFuture<?>	schedule(Callable<?> callable, long delay, TimeUnit unit)	Schedules the callable to be called after the delay for the unit.

Methods inherited from class Object

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

Field Details

INSTANCE

public static final DelegatingScheduler INSTANCE

FORK_JOIN_POOL

private static volatile ForkJoinPool FORK_JOIN_POOL

DELAYER

private static volatile ScheduledThreadPoolExecutor DELAYER

executorService

private final ExecutorService executorService

Constructor Details

DelegatingScheduler

private DelegatingScheduler()

DelegatingScheduler

public DelegatingScheduler(ExecutorService executor)

Method Details

delayer

private static ScheduledExecutorService delayer()

executorService

private ExecutorService executorService()

schedule

public ScheduledFuture<?> schedule(Callable<?> callable,
 long delay,
 TimeUnit unit)

Description copied from interface: Scheduler

Schedules the callable to be called after the delay for the unit.

Specified by:

schedule in interface Scheduler