Uses of Interface
dev.failsafe.spi.Scheduler

Packages that use Scheduler

Package	Description
dev.failsafe	APIs for performing failsafe executions.
dev.failsafe.internal
dev.failsafe.internal.util
dev.failsafe.spi	The Failsafe Service Provider Interface (SPI).

Uses of Scheduler in dev.failsafe

Methods in dev.failsafe with parameters of type Scheduler

Modifier and Type	Method	Description
FailsafeExecutor<R>	FailsafeExecutor.with(Scheduler scheduler)	Configures the scheduler to use for performing asynchronous executions and listener callbacks.

Uses of Scheduler in dev.failsafe.internal

Methods in dev.failsafe.internal with parameters of type Scheduler

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>, ExecutionResult<R>>	FallbackExecutor.apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier, applying a fallback if it fails, and calling post-execute.
Function<SyncExecutionInternal<R>, ExecutionResult<R>>	RetryPolicyExecutor.apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn, Scheduler scheduler)
Function<SyncExecutionInternal<R>, ExecutionResult<R>>	TimeoutExecutor.apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn, Scheduler scheduler)	Schedules a separate timeout call that fails with TimeoutExceededException if the policy's timeout is exceeded.
Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	FallbackExecutor.applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	RetryPolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)
Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	TimeoutExecutor.applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Schedules a separate timeout call that blocks and fails with TimeoutExceededException if the policy's timeout is exceeded.
Object	RetryPolicyExecutor.handleAsync(AsyncExecutionInternal<R> execution, Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future, CompletableFuture<ExecutionResult<R>> promise, AtomicReference<ExecutionResult<R>> previousResultRef)
CompletableFuture<ExecutionResult<R>>	RetryPolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Defaults async executions to not be complete until says they are.
protected CompletableFuture<ExecutionResult<R>>	BulkheadExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)
protected CompletableFuture<ExecutionResult<R>>	RateLimiterExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)

Uses of Scheduler in dev.failsafe.internal.util

Classes in dev.failsafe.internal.util that implement Scheduler

Modifier and Type	Class	Description
final class	DelegatingScheduler	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.

Uses of Scheduler in dev.failsafe.spi

Fields in dev.failsafe.spi declared as Scheduler

Modifier and Type	Field	Description
static final Scheduler	Scheduler.DEFAULT	The default scheduler used by Failsafe if no other scheduler or ScheduledExecutorService is configured for an execution.

Methods in dev.failsafe.spi that return Scheduler

Modifier and Type	Method	Description
static Scheduler	Scheduler.of(ExecutorService executorService)	Returns a Scheduler adapted from the executorService.
static Scheduler	Scheduler.of(ScheduledExecutorService scheduledExecutorService)	Returns a Scheduler adapted from the scheduledExecutorService.

Methods in dev.failsafe.spi with parameters of type Scheduler

Modifier and Type	Method	Description
Function<SyncExecutionInternal<R>, ExecutionResult<R>>	PolicyExecutor.apply(Function<SyncExecutionInternal<R>, ExecutionResult<R>> innerFn, Scheduler scheduler)	Performs an execution by calling pre-execute else calling the supplier and doing a post-execute.
Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>>	PolicyExecutor.applyAsync(Function<AsyncExecutionInternal<R>, CompletableFuture<ExecutionResult<R>>> innerFn, Scheduler scheduler, FailsafeFuture<R> future)	Performs an async execution by calling pre-execute else calling the supplier and doing a post-execute.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.onFailureAsync(ExecutionContext<R> context, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchrononus post-execution handling for a failed result, possibly creating a new result, else returning the original result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.postExecuteAsync(AsyncExecutionInternal<R> execution, ExecutionResult<R> result, Scheduler scheduler, FailsafeFuture<R> future)	Performs potentially asynchronous post-execution handling for a result.
protected CompletableFuture<ExecutionResult<R>>	PolicyExecutor.preExecuteAsync(Scheduler scheduler, FailsafeFuture<R> future)	Called before an async execution to return an alternative result or exception such as if execution is not allowed or needed.