com.graphaware.runtime.schedule

Class FixedDelayTimingStrategy

java.lang.Object

com.graphaware.runtime.schedule.FixedDelayTimingStrategy

All Implemented Interfaces:

TimingStrategy

public class FixedDelayTimingStrategy
extends Object
implements TimingStrategy

TimingStrategy that causes tasks to be scheduled in regular intervals.

Field Summary

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

NEVER_RUN, UNKNOWN

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static FixedDelayTimingStrategy	getInstance()
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.
FixedDelayTimingStrategy	withDelay(long delay) Create a new strategy with a different fixed delay.
FixedDelayTimingStrategy	withInitialDelay(long initialDelay) Create a new strategy with a different initial delay.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static FixedDelayTimingStrategy getInstance()

withInitialDelay

public FixedDelayTimingStrategy withInitialDelay(long initialDelay)

Create a new strategy with a different initial delay.

Parameters:

initialDelay - of the new strategy.

Returns:

new strategy.

withDelay

public FixedDelayTimingStrategy withDelay(long delay)

Create a new strategy with a different fixed delay.

Parameters:

delay - of the new strategy.

Returns:

new strategy.

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