org.spf4j.base

Class CallablesNano

java.lang.Object

org.spf4j.base.CallablesNano

Deprecated.

use RetryPolicy & co.

@ParametersAreNonnullByDefault
 @Beta
 @Deprecated
public final class CallablesNano
extends Object

Utility class for executing stuff with retry logic.

Author:

zoly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CallablesNano.NanoTimeoutCallable<T,EX extends Exception> Deprecated.
static interface	CallablesNano.TimeoutNanoRetryPredicate<T,R> Deprecated.

Method Summary

Modifier and Type	Method and Description
static <T,EX extends Exception> T	executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what, CallablesNano.TimeoutNanoRetryPredicate<Exception,T> retryOnException, Class<EX> exceptionClass) Deprecated.
static <T,EX extends Exception> T	executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what, CallablesNano.TimeoutNanoRetryPredicate<T,T> retryOnReturnVal, CallablesNano.TimeoutNanoRetryPredicate<Exception,T> retryOnException, Class<EX> exceptionClass) Deprecated.
static <T,EX extends Exception> T	executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what, int nrImmediateRetries, long maxRetryWaitNanos, Callables.AdvancedRetryPredicate<Exception> retryOnException, Class<EX> exceptionClass) Deprecated.
static <T,EX extends Exception> T	executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what, int nrImmediateRetries, long maxWaitNanos, CallablesNano.TimeoutNanoRetryPredicate<? super T,T> retryOnReturnVal, Callables.AdvancedRetryPredicate<Exception> retryOnException, Class<EX> exceptionClass) Deprecated. After the immediate retries are done, delayed retry with randomized Fibonacci values up to the specified max is executed.
static <T,EX extends Exception> T	executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what, int nrImmediateRetries, long maxRetryWaitNanos, Class<EX> exceptionClass) Deprecated.
static long	toDeadlineNanos(long timeoutNanos) Deprecated.

Methods inherited from class java.lang.Object

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

Method Detail

executeWithRetry

public static <T,EX extends Exception> T executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what,
                                                          int nrImmediateRetries,
                                                          long maxRetryWaitNanos,
                                                          Class<EX> exceptionClass)
                                                   throws InterruptedException,
                                                          EX extends Exception,
                                                          TimeoutException

Deprecated.

Throws:

InterruptedException

EX extends Exception

TimeoutException

executeWithRetry

public static <T,EX extends Exception> T executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what,
                                                          int nrImmediateRetries,
                                                          long maxRetryWaitNanos,
                                                          Callables.AdvancedRetryPredicate<Exception> retryOnException,
                                                          Class<EX> exceptionClass)
                                                   throws InterruptedException,
                                                          EX extends Exception,
                                                          TimeoutException

Deprecated.

Throws:

InterruptedException

EX extends Exception

TimeoutException

executeWithRetry

public static <T,EX extends Exception> T executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what,
                                                          int nrImmediateRetries,
                                                          long maxWaitNanos,
                                                          CallablesNano.TimeoutNanoRetryPredicate<? super T,T> retryOnReturnVal,
                                                          Callables.AdvancedRetryPredicate<Exception> retryOnException,
                                                          Class<EX> exceptionClass)
                                                   throws InterruptedException,
                                                          EX extends Exception,
                                                          TimeoutException

Deprecated.

After the immediate retries are done, delayed retry with randomized Fibonacci values up to the specified max is executed.

Type Parameters:

T - - the type returned by the Callable that is retried.

EX - - the Exception thrown by the retried callable.

Parameters:

what - - the callable to retry.

nrImmediateRetries - - the number of immediate retries.

maxWaitNanos - - maximum wait time in between retries.

retryOnReturnVal - - predicate to control retry on return value;

retryOnException - - predicate to retry on thrown exception.

Returns:

the result of the callable.

Throws:

InterruptedException - - thrown if interrupted.

EX - - the exception declared to be thrown by the callable.

EX extends Exception

TimeoutException

toDeadlineNanos

public static long toDeadlineNanos(long timeoutNanos)

Deprecated.

executeWithRetry

public static <T,EX extends Exception> T executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what,
                                                          CallablesNano.TimeoutNanoRetryPredicate<T,T> retryOnReturnVal,
                                                          CallablesNano.TimeoutNanoRetryPredicate<Exception,T> retryOnException,
                                                          Class<EX> exceptionClass)
                                                   throws InterruptedException,
                                                          EX extends Exception,
                                                          TimeoutException

Deprecated.

Throws:

InterruptedException

EX extends Exception

TimeoutException

executeWithRetry

public static <T,EX extends Exception> T executeWithRetry(CallablesNano.NanoTimeoutCallable<T,EX> what,
                                                          CallablesNano.TimeoutNanoRetryPredicate<Exception,T> retryOnException,
                                                          Class<EX> exceptionClass)
                                                   throws InterruptedException,
                                                          EX extends Exception,
                                                          TimeoutException

Deprecated.

Throws:

InterruptedException

EX extends Exception

TimeoutException