org.daisy.pipeline.tts.scheduler

Class ExponentialBackoffScheduler<Action extends Schedulable>

java.lang.Object

org.daisy.pipeline.tts.scheduler.ExponentialBackoffScheduler<Action>

Type Parameters:

Action - class of request objects to handle

All Implemented Interfaces:

Scheduler<Action>

public class ExponentialBackoffScheduler<Action extends Schedulable>
extends Object
implements Scheduler<Action>

Scheduler that increases the delay between actions launch, using a number of seconds equals to apower of 2 times retries and a random number of milliseconds.

This scheduler implementation is based on Google and Amazon recommendations.

Author:

Louis Caille @ braillenet.org

Constructor Summary

Constructors

Constructor and Description
ExponentialBackoffScheduler()

Method Summary

Modifier and Type	Method and Description
void	launch(Action action) When a recoverable error is thrown, the scheduler keep the action in its queue and delays all launches by sleeping the thread while in locked state

Methods inherited from class java.lang.Object

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

Constructor Detail

ExponentialBackoffScheduler

public ExponentialBackoffScheduler()

Method Detail

launch

public void launch(Action action)
            throws InterruptedException,
                   FatalError

When a recoverable error is thrown, the scheduler keep the action in its queue and delays all launches by sleeping the thread while in locked state

Specified by:

launch in interface Scheduler<Action extends Schedulable>

Parameters:

action - the action to launch

Throws:

InterruptedException - if the scheduler thread is interrupted

FatalError - if the action could not be executed or rescheduled after a RecoverableError