Package org.ros.concurrent

Class RetryingExecutorService

java.lang.Object

org.ros.concurrent.RetryingExecutorService

public class RetryingExecutorService
extends Object

Wraps an ScheduledExecutorService to execute Callables with retries.

Author:

damonkohler@google.com (Damon Kohler)

Constructor Summary

Constructors

Constructor	Description
RetryingExecutorService(ScheduledExecutorService scheduledExecutorService)

Method Summary

Modifier and Type	Method	Description
void	setRetryDelay(long delay, TimeUnit unit)
void	shutdown(long timeout, TimeUnit unit)	Stops accepting new Callables and waits for all submitted Callables to finish within the specified timeout.
void	submit(Callable<Boolean> callable)	Submit a new Callable to be executed.

Methods inherited from class java.lang.Object

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

Constructor Details

RetryingExecutorService

public RetryingExecutorService(ScheduledExecutorService scheduledExecutorService)

Parameters:

scheduledExecutorService - the ExecutorService to wrap

Method Details

submit

public void submit(Callable<Boolean> callable)

Submit a new Callable to be executed. The submitted Callable should return true to be retried, false otherwise.

Parameters:

callable - the Callable to execute

Throws:

RejectedExecutionException - if the RetryingExecutorService is shutting down

setRetryDelay

public void setRetryDelay(long delay,
 TimeUnit unit)

Parameters:

delay - the delay in units of unit

unit - the TimeUnit of the delay

shutdown

public void shutdown(long timeout,
 TimeUnit unit)
              throws InterruptedException

Stops accepting new Callables and waits for all submitted Callables to finish within the specified timeout.

Parameters:

timeout - the timeout in units of unit

unit - the TimeUnit of timeout

Throws:

InterruptedException