com.graphaware.runtime.schedule

Class AdaptiveTimingStrategy

java.lang.Object

com.graphaware.runtime.schedule.AdaptiveTimingStrategy

All Implemented Interfaces:

TimingStrategy

public class AdaptiveTimingStrategy
extends Object
implements TimingStrategy

Implementation of TimingStrategy that pays attention to the current level of activity in the database, i.e. the number of started transactions, in order to decide how long to wait before scheduling the next task.

Field Summary

Fields inherited from interface com.graphaware.runtime.schedule.TimingStrategy

NEVER_RUN, UNKNOWN

Method Summary

Modifier and Type	Method and Description
static AdaptiveTimingStrategy	defaultConfiguration() Create a new instance of this strategy with default configuration, which is: delta = 100ms default delay = 2s minimum delay = 5ms maximum delay = 10s busy threshold = 100 maximum samples = 200 maximum time = 2s
boolean	equals(Object o)
int	hashCode()
void	initialize(org.neo4j.graphdb.GraphDatabaseService database) Initialize the timing strategy before it can be used.
long	nextDelay(long lastTaskDuration) Get the delay until the timer fires again.
AdaptiveTimingStrategy	withBusyThreshold(int busyThreshold) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the given busy threshold.
AdaptiveTimingStrategy	withDefaultDelayMillis(long defaultDelay) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified default timer-driven module scheduling delay.
AdaptiveTimingStrategy	withDelta(long delta) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified delta.
AdaptiveTimingStrategy	withMaximumDelayMillis(long maxDelay) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified maximum delay between timer-driven module invocations.
AdaptiveTimingStrategy	withMaxSamples(int maxSamples) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the maximum number of samples.
AdaptiveTimingStrategy	withMaxTime(int maxTime) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the given maximum running average window time span.
AdaptiveTimingStrategy	withMinimumDelayMillis(long minDelay) Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified minimum delay between timer-driven module invocations.

Methods inherited from class java.lang.Object

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

Method Detail

defaultConfiguration

public static AdaptiveTimingStrategy defaultConfiguration()

Create a new instance of this strategy with default configuration, which is:

• delta = 100ms
• default delay = 2s
• minimum delay = 5ms
• maximum delay = 10s
• busy threshold = 100
• maximum samples = 200
• maximum time = 2s

Returns:

instance of this strategy.

withDelta

public AdaptiveTimingStrategy withDelta(long delta)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified delta.

Parameters:

delta - The new delta in milliseconds.

Returns:

A new AdaptiveTimingStrategy.

withDefaultDelayMillis

public AdaptiveTimingStrategy withDefaultDelayMillis(long defaultDelay)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified default timer-driven module scheduling delay.

Parameters:

defaultDelay - The new default scheduling delay in milliseconds.

Returns:

A new AdaptiveTimingStrategy.

withMinimumDelayMillis

public AdaptiveTimingStrategy withMinimumDelayMillis(long minDelay)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified minimum delay between timer-driven module invocations.

Parameters:

minDelay - The new minimum delay between timer-driven module invocations.

Returns:

A new AdaptiveTimingStrategy.

withMaximumDelayMillis

public AdaptiveTimingStrategy withMaximumDelayMillis(long maxDelay)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the specified maximum delay between timer-driven module invocations.

Parameters:

maxDelay - The new maximum delay between timer-driven module invocations.

Returns:

A new AdaptiveTimingStrategy.

withBusyThreshold

public AdaptiveTimingStrategy withBusyThreshold(int busyThreshold)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the given busy threshold.

Parameters:

busyThreshold - The new busy threshold to use.

Returns:

A new AdaptiveTimingStrategy.

withMaxSamples

public AdaptiveTimingStrategy withMaxSamples(int maxSamples)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the maximum number of samples.

Parameters:

maxSamples - The new maximum number of samples to use.

Returns:

A new AdaptiveTimingStrategy.

withMaxTime

public AdaptiveTimingStrategy withMaxTime(int maxTime)

Returns a copy of this AdaptiveTimingStrategy reconfigured to use the given maximum running average window time span.

Parameters:

maxTime - The new maximum time to use.

Returns:

A new AdaptiveTimingStrategy.

initialize

public void initialize(org.neo4j.graphdb.GraphDatabaseService database)

Initialize the timing strategy before it can be used.

Specified by:

initialize in interface TimingStrategy

Parameters:

database - against which the runtime using this strategy runs.

nextDelay

public long nextDelay(long lastTaskDuration)

Get the delay until the timer fires again.

Specified by:

nextDelay in interface TimingStrategy

Parameters:

lastTaskDuration - The total time it took to execute the last task in milliseconds. -1 if unknown.

Returns:

The next delay in milliseconds.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object