Package | Description |
---|---|
org.spf4j.base |
Modifier and Type | Class and Description |
---|---|
static class |
Callables.RetryPauseWithTimeout<T> |
Modifier and Type | Method and Description |
---|---|
static <T> Callables.PreRetryCallback<T> |
Callables.callableToPreRetryCallback(Callable<Boolean> doBeforeRetry) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
Callables.executeWithRetry(Callable<T> what,
Callables.PreRetryCallback<T> doBeforeRetry,
com.google.common.base.Predicate<? super T> retryOnReturnVal,
com.google.common.base.Predicate<Exception> retryOnException)
Naive implementation of execution with retry logic.
|
static <T> T |
Callables.executeWithRetry(Callables.TimeoutCallable<T> what,
Callables.PreRetryCallback<T> doBeforeRetry,
int nrImmediateRetries,
int maxWaitMillis,
com.google.common.base.Predicate<? super T> retryOnReturnVal,
com.google.common.base.Predicate<Exception> retryOnException)
After the immediate retries are done,
delayed retry with randomized Fibonacci values up to the specified max is executed.
|
Constructor and Description |
---|
Callables.RetryPauseWithTimeout(int nrImmediateRetries,
int maxRetryWaitMillis,
long deadline,
Callables.PreRetryCallback<T> doBeforeRetry) |
Copyright © 2014. All rights reserved.