Package com.google.api.gax.retrying

Class ScheduledRetryingExecutor<ResponseT>

java.lang.Object

com.google.api.gax.retrying.ScheduledRetryingExecutor<ResponseT>

Type Parameters:

ResponseT - response type

All Implemented Interfaces:

RetryingExecutor<ResponseT>, RetryingExecutorWithContext<ResponseT>

public class ScheduledRetryingExecutor<ResponseT>
extends Object
implements RetryingExecutorWithContext<ResponseT>

The retry executor which uses ScheduledExecutorService to schedule an attempt tasks.

This implementation does not manage the lifecycle of the underlying ScheduledExecutorService, so it should be managed outside of this class (like calling the ExecutorService.shutdown() when the pool is not needed anymore). In a typical usage pattern there are usually multiple instances of this class sharing same instance of the underlying ScheduledExecutorService.

This class is thread-safe.

Constructor Summary

Constructors

Constructor	Description
ScheduledRetryingExecutor(RetryAlgorithm<ResponseT> retryAlgorithm, ScheduledExecutorService scheduler)	Creates a new scheduled retry executor, which will be using scheduler for actual attempts scheduling and retryAlgorithm for retrying strategy.

Method Summary

Modifier and Type	Method	Description
RetryingFuture<ResponseT>	createFuture(Callable<ResponseT> callable)	Creates a RetryingFuture, which is a facade, returned to the client code to wait for any retriable operation to complete.
RetryingFuture<ResponseT>	createFuture(Callable<ResponseT> callable, RetryingContext context)	Creates a RetryingFuture, which is a facade, returned to the client code to wait for any retriable operation to complete.
com.google.api.core.ApiFuture<ResponseT>	submit(RetryingFuture<ResponseT> retryingFuture)	Submits an attempt for execution in a different thread.

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledRetryingExecutor

public ScheduledRetryingExecutor(RetryAlgorithm<ResponseT> retryAlgorithm,
                                 ScheduledExecutorService scheduler)

Creates a new scheduled retry executor, which will be using scheduler for actual attempts scheduling and retryAlgorithm for retrying strategy.

Parameters:

retryAlgorithm - retry algorithm to use

scheduler - scheduler

Method Detail

createFuture

public RetryingFuture<ResponseT> createFuture(Callable<ResponseT> callable)

Creates a RetryingFuture, which is a facade, returned to the client code to wait for any retriable operation to complete. The returned future is bounded to this executor instance.

Specified by:

createFuture in interface RetryingExecutor<ResponseT>

Parameters:

callable - the actual callable, which should be executed in a retriable context

Returns:

retrying future facade

createFuture

@BetaApi("The surface for passing per operation state is not yet stable")
public RetryingFuture<ResponseT> createFuture(Callable<ResponseT> callable,
                                              RetryingContext context)

Creates a RetryingFuture, which is a facade, returned to the client code to wait for any retriable operation to complete. The returned future is bounded to this executor instance.

Specified by:

createFuture in interface RetryingExecutorWithContext<ResponseT>

Parameters:

callable - the actual callable, which should be executed in a retriable context

context - the context for this operation

Returns:

retrying future facade

submit

public com.google.api.core.ApiFuture<ResponseT> submit(RetryingFuture<ResponseT> retryingFuture)

Submits an attempt for execution in a different thread.

Specified by:

submit in interface RetryingExecutor<ResponseT>

Parameters:

retryingFuture - the future previously returned by createFuture(Callable, RetryingContext)

Returns:

submitted attempt future