Package org.apache.bookkeeper.client

Class DefaultSpeculativeRequestExecutionPolicy

java.lang.Object

org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy

All Implemented Interfaces:

SpeculativeRequestExecutionPolicy

public class DefaultSpeculativeRequestExecutionPolicy
extends Object
implements SpeculativeRequestExecutionPolicy

A default implementation of SpeculativeRequestExecutionPolicy.

The policy issues speculative requests in a backoff way. The time between two speculative requests are between firstSpeculativeRequestTimeout and maxSpeculativeRequestTimeout.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final float	backoffMultiplier
(package private) final int	firstSpeculativeRequestTimeout
(package private) final int	maxSpeculativeRequestTimeout

Constructor Summary

Constructors

Constructor	Description
DefaultSpeculativeRequestExecutionPolicy(int firstSpeculativeRequestTimeout, int maxSpeculativeRequestTimeout, float backoffMultiplier)

Method Summary

Modifier and Type	Method	Description
ScheduledFuture<?>	initiateSpeculativeRequest(ScheduledExecutorService scheduler, SpeculativeRequestExecutor requestExecutor)	Initialize the speculative request execution policy.

Methods inherited from class java.lang.Object

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

Field Details

firstSpeculativeRequestTimeout

final int firstSpeculativeRequestTimeout

maxSpeculativeRequestTimeout

final int maxSpeculativeRequestTimeout

backoffMultiplier

final float backoffMultiplier

Constructor Details

DefaultSpeculativeRequestExecutionPolicy

public DefaultSpeculativeRequestExecutionPolicy(int firstSpeculativeRequestTimeout,
 int maxSpeculativeRequestTimeout,
 float backoffMultiplier)

Method Details

initiateSpeculativeRequest

public ScheduledFuture<?> initiateSpeculativeRequest(ScheduledExecutorService scheduler,
 SpeculativeRequestExecutor requestExecutor)

Initialize the speculative request execution policy.

Specified by:

initiateSpeculativeRequest in interface SpeculativeRequestExecutionPolicy

Parameters:

scheduler - The scheduler service to issue the speculative request

requestExecutor - The executor is used to issue the actual speculative requests

Returns:

ScheduledFuture, in case caller needs to cancel it.