org.spf4j.failsafe

Interface AsyncRetryExecutor<T,C extends Callable<? extends T>>

All Superinterfaces:

SyncRetryExecutor<T,C>

@ThreadSafe
public interface AsyncRetryExecutor<T,C extends Callable<? extends T>>
extends SyncRetryExecutor<T,C>

Author:

Zoltan Farkas

Method Summary

Modifier and Type	Method and Description
static <T,C extends Callable<? extends T>> AsyncRetryExecutor<T,C>	defaultAsyncRetryExecutor()
default <W extends C> void	execute(W pwhat)
<W extends C> void	execute(W pwhat, long startTimeNanos, long deadlineNanos)
default <W extends C> void	execute(W pwhat, long timeout, TimeUnit tu)
static <T,C extends Callable<? extends T>> AsyncRetryExecutor<T,C>	noRetryAsyncExecutor()
default <R extends T,W extends C> Future<R>	submit(W pwhat)
default <R extends T,W extends C> Future<R>	submit(W pwhat, long deadlineNanos)
<R extends T,W extends C> Future<R>	submit(W pwhat, long startTimeNanos, long deadlineNanos)
default <R extends T,W extends C> Future<R>	submit(W pwhat, long timeout, TimeUnit tu)

Methods inherited from interface org.spf4j.failsafe.SyncRetryExecutor

call, call, call, call, call, run, run, run

Method Detail

submit

@CheckReturnValue
default <R extends T,W extends C> Future<R> submit(W pwhat)

submit

@CheckReturnValue
default <R extends T,W extends C> Future<R> submit(W pwhat,
                                                                     long deadlineNanos)

submit

@CheckReturnValue
<R extends T,W extends C> Future<R> submit(W pwhat,
                                                             long startTimeNanos,
                                                             long deadlineNanos)

submit

@CheckReturnValue
default <R extends T,W extends C> Future<R> submit(W pwhat,
                                                                     long timeout,
                                                                     TimeUnit tu)

execute

default <W extends C> void execute(W pwhat)

execute

<W extends C> void execute(W pwhat,
                           long startTimeNanos,
                           long deadlineNanos)

execute

default <W extends C> void execute(W pwhat,
                                   long timeout,
                                   TimeUnit tu)

defaultAsyncRetryExecutor

static <T,C extends Callable<? extends T>> AsyncRetryExecutor<T,C> defaultAsyncRetryExecutor()

noRetryAsyncExecutor

static <T,C extends Callable<? extends T>> AsyncRetryExecutor<T,C> noRetryAsyncExecutor()