io.atlassian.fugue.retry

Class BeforeRetryExponentialBackoffTask

java.lang.Object

io.atlassian.fugue.retry.BeforeRetryExponentialBackoffTask

All Implemented Interfaces:

Runnable

public class BeforeRetryExponentialBackoffTask
extends Object
implements Runnable

A backoff task for use in a retry -function, -supplier, or -task. This should be used as the beforeRetry hook. Upon each execution, the amount of time to wait before retrying the function call is doubled. This class maintains an internal state; we recommend creating a new instance for each use.

Constructor Summary

Constructors

Constructor and Description
BeforeRetryExponentialBackoffTask(long backoffMillis) Constructor for BeforeRetryExponentialBackoffTask.

Method Summary

Modifier and Type	Method and Description
void	run() This method causes the current thread to sleep for a duration which doubles after each successive call.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeforeRetryExponentialBackoffTask

public BeforeRetryExponentialBackoffTask(long backoffMillis)

Constructor for BeforeRetryExponentialBackoffTask.

Parameters:

backoffMillis - the amount of time to wait, in milliseconds before retrying the first time. This is doubled for each subsequent retry. This parameter must be above zero.

Method Detail

run

public void run()

This method causes the current thread to sleep for a duration which doubles after each successive call. InterruptedExceptions are wrapped before being rethrown in a RuntimeException.

Specified by:

run in interface Runnable