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.

Author:

Jonathan Halterman, Ben Manes

Field Summary

Fields

Modifier and Type	Field	Description
static final DelegatingScheduler	INSTANCE

Fields inherited from interface Scheduler

DEFAULT

Constructor Summary

Constructors

Constructor	Description
DelegatingScheduler(ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
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

Constructor Details

DelegatingScheduler

public DelegatingScheduler(ExecutorService executor)

Method Details

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