public class RetryExecutor<T> extends Object implements ExecutorService
| Constructor and Description |
|---|
RetryExecutor(ExecutorService exec,
int nrImmediateRetries,
int nrTotalRetries,
long delayMillis,
com.google.common.base.Predicate<Exception> retryException,
BlockingQueue<Future<T>> completionQueue) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isTerminated() |
void |
shutdown() |
List<Runnable> |
shutdownNow() |
<A> Future<A> |
submit(Callable<A> task) |
Future<?> |
submit(Runnable task) |
<A> Future<A> |
submit(Runnable task,
A result) |
public RetryExecutor(ExecutorService exec, int nrImmediateRetries, int nrTotalRetries, long delayMillis, com.google.common.base.Predicate<Exception> retryException, @Nullable BlockingQueue<Future<T>> completionQueue)
public final void shutdown()
shutdown in interface ExecutorServicepublic final List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic final boolean isShutdown()
isShutdown in interface ExecutorServicepublic final boolean isTerminated()
isTerminated in interface ExecutorServicepublic final boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic final <A> Future<A> submit(Callable<A> task)
submit in interface ExecutorServicepublic final <A> Future<A> submit(Runnable task, A result)
submit in interface ExecutorServicepublic final Future<?> submit(Runnable task)
submit in interface ExecutorServicepublic final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic final <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionCopyright © 2014. All rights reserved.