org.spf4j.failsafe

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

All Known Subinterfaces:

AsyncRetryExecutor<T,C>

All Known Implementing Classes:

RetryPolicy

public interface SyncRetryExecutor<T,C extends Callable<? extends T>>

Author:

Zoltan Farkas

Method Summary

Modifier and Type	Method and Description
static <T,E extends Exception,C extends Callable<? extends T>> T	call(C pwhat, RetryPredicate<T,C> retryPredicate, Class<E> exceptionClass, int maxExceptionChain) Naive implementation of execution with retry logic.
default <R extends T,W extends C,E extends Exception> R	call(W pwhat, Class<E> exceptionClass)
default <R extends T,W extends C,E extends Exception> R	call(W pwhat, Class<E> exceptionClass, long deadlineNanos)
<R extends T,W extends C,E extends Exception> R	call(W pwhat, Class<E> exceptionClass, long startNanos, long deadlineNanos)
default <R extends T,W extends C,E extends Exception> R	call(W pwhat, Class<E> exceptionClass, long timeout, TimeUnit tu)
default <W extends C,E extends Exception> void	run(W pwhat, Class<E> exceptionClass)
default <W extends C,E extends Exception> void	run(W pwhat, Class<E> exceptionClass, long deadlineNanos)
default <E extends Exception,W extends C> void	run(W pwhat, Class<E> exceptionClass, long timeout, TimeUnit tu)

Method Detail

call

@CheckReturnValue
<R extends T,W extends C,E extends Exception> R call(W pwhat,
                                                                       Class<E> exceptionClass,
                                                                       long startNanos,
                                                                       long deadlineNanos)
                                                                throws InterruptedException,
                                                                       TimeoutException,
                                                                       E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

call

@CheckReturnValue
default <R extends T,W extends C,E extends Exception> R call(W pwhat,
                                                                               Class<E> exceptionClass,
                                                                               long deadlineNanos)
                                                                        throws InterruptedException,
                                                                               TimeoutException,
                                                                               E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

call

@CheckReturnValue
default <R extends T,W extends C,E extends Exception> R call(W pwhat,
                                                                               Class<E> exceptionClass)
                                                                        throws InterruptedException,
                                                                               TimeoutException,
                                                                               E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

call

@CheckReturnValue
default <R extends T,W extends C,E extends Exception> R call(W pwhat,
                                                                               Class<E> exceptionClass,
                                                                               long timeout,
                                                                               TimeUnit tu)
                                                                        throws InterruptedException,
                                                                               TimeoutException,
                                                                               E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

run

default <W extends C,E extends Exception> void run(W pwhat,
                                                   Class<E> exceptionClass)
                                            throws InterruptedException,
                                                   TimeoutException,
                                                   E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

run

default <W extends C,E extends Exception> void run(W pwhat,
                                                   Class<E> exceptionClass,
                                                   long deadlineNanos)
                                            throws InterruptedException,
                                                   TimeoutException,
                                                   E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

run

default <E extends Exception,W extends C> void run(W pwhat,
                                                   Class<E> exceptionClass,
                                                   long timeout,
                                                   TimeUnit tu)
                                            throws InterruptedException,
                                                   TimeoutException,
                                                   E extends Exception

Throws:

InterruptedException

TimeoutException

E extends Exception

call

static <T,E extends Exception,C extends Callable<? extends T>> T call(C pwhat,
                                                                      RetryPredicate<T,C> retryPredicate,
                                                                      Class<E> exceptionClass,
                                                                      int maxExceptionChain)
                                                               throws InterruptedException,
                                                                      TimeoutException,
                                                                      E extends Exception

Naive implementation of execution with retry logic. a callable will be executed and retry attempted in current thread if the result and exception predicates. before retry, a callable can be executed that can abort the retry and finish the function with the previous result.

Type Parameters:

T - - The type of callable to retry result;

EX - - the exception thrown by the callable to retry.

Parameters:

pwhat - - the callable to retry.

Returns:

the result of the retried callable if successful.

Throws:

InterruptedException - - thrown if retry interrupted.

EX - - the exception thrown by callable.

TimeoutException

E extends Exception