com.graphaware.runtime.schedule

Class ConstantDeltaDelayAdjuster

java.lang.Object

com.graphaware.runtime.schedule.ConstantDeltaDelayAdjuster

All Implemented Interfaces:

DelayAdjuster

public class ConstantDeltaDelayAdjuster
extends Object
implements DelayAdjuster

Simple implementation of DelayAdjuster that makes adjustments of a constant size depending on the activity delta and threshold values.

Constructor Summary

Constructors

Constructor and Description
ConstantDeltaDelayAdjuster(long delta, long defaultDelay, long minDelay, long maxDelay, long busyThreshold) Constructs a new ConstantDeltaDelayAdjuster that lengthens (iff the database is busy) or shortens the delay by the given amount.

Method Summary

Modifier and Type	Method and Description
long	determineNextDelay(long currentDelay, long lastTaskDuration, long load) Determines the absolute number of milliseconds that should be used as the next timing delay for scheduling a module invocation based on the given arguments.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConstantDeltaDelayAdjuster

public ConstantDeltaDelayAdjuster(long delta,
                                  long defaultDelay,
                                  long minDelay,
                                  long maxDelay,
                                  long busyThreshold)

Constructs a new ConstantDeltaDelayAdjuster that lengthens (iff the database is busy) or shortens the delay by the given amount.

Parameters:

delta - The number of milliseconds by which to adjust the current delay.

defaultDelay - The number of milliseconds to return if there is not enough information to make a better decision.

minDelay - The lower limit to the delay that can be returned as the next delay.

maxDelay - The upper limit to the delay that can be returned as the next delay.

busyThreshold - the number of transactions per second, above which the database is deemed to be busy.

Method Detail

determineNextDelay

public long determineNextDelay(long currentDelay,
                               long lastTaskDuration,
                               long load)

Determines the absolute number of milliseconds that should be used as the next timing delay for scheduling a module invocation based on the given arguments.

Specified by:

determineNextDelay in interface DelayAdjuster

Parameters:

currentDelay - The currently-used delay length in milliseconds - i.e., the base value to adjust.

lastTaskDuration - The number of milliseconds taken to execute the previously-scheduled task.

load - The load on the database in tx/s.

Returns:

The absolute number of milliseconds that should be used for the next scheduling delay.