org.spf4j.failsafe.concurrent

Class RetryExecutor

java.lang.Object

org.spf4j.failsafe.concurrent.RetryExecutor

All Implemented Interfaces:

AutoCloseable

public final class RetryExecutor
extends Object
implements AutoCloseable

Executor that will call Callables with retry. This executor cannot be used inside a Completion service.

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
RetryExecutor(ExecutorService exec)
RetryExecutor(ExecutorService exec, BlockingQueue<Future<?>> completionQueue)

Method Summary

Modifier and Type	Method and Description
void	close()
<A,C extends Callable<? extends A>> void	execute(C command, RetryPredicate<A,C> predicate)
void	execute(Runnable command, RetryPredicate<Void,Callable<Void>> predicate)
void	initiateClose()
<A,C extends Callable<? extends A>> Future<A>	submit(C task, RetryPredicate<A,C> predicate)
<A> Future<A>	submit(Runnable task, A result, RetryPredicate<A,? extends Callable<? extends A>> predicate)
Future<?>	submit(Runnable task, RetryPredicate<Void,Callable<Void>> predicate)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryExecutor

public RetryExecutor(ExecutorService exec)

RetryExecutor

public RetryExecutor(ExecutorService exec,
                     @Nullable
                     BlockingQueue<Future<?>> completionQueue)

Method Detail

close

public void close()
           throws InterruptedException

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException

initiateClose

public void initiateClose()

submit

public <A,C extends Callable<? extends A>> Future<A> submit(C task,
                                                            RetryPredicate<A,C> predicate)

submit

public <A> Future<A> submit(Runnable task,
                            A result,
                            RetryPredicate<A,? extends Callable<? extends A>> predicate)

submit

public Future<?> submit(Runnable task,
                        RetryPredicate<Void,Callable<Void>> predicate)

execute

public void execute(Runnable command,
                    RetryPredicate<Void,Callable<Void>> predicate)

execute

public <A,C extends Callable<? extends A>> void execute(C command,
                                                        RetryPredicate<A,C> predicate)

toString

public String toString()

Overrides:

toString in class Object