com.graphaware.runtime.schedule

Class RotatingTaskScheduler

java.lang.Object

com.graphaware.runtime.schedule.RotatingTaskScheduler

All Implemented Interfaces:

TaskScheduler

public class RotatingTaskScheduler
extends Object
implements TaskScheduler

TaskScheduler that delegates to the registered TimerDrivenModules in round-robin fashion, in the order in which the modules were registered. All work performed by this implementation is done by a single thread.

Constructor Summary

Constructors

Constructor and Description
RotatingTaskScheduler(org.neo4j.graphdb.GraphDatabaseService database, ModuleMetadataRepository repository, TimingStrategy timingStrategy) Construct a new task scheduler.

Method Summary

Modifier and Type	Method and Description
protected boolean	hasCorrectRole(TimerDrivenModule<?> module) Check if the given module has the correct role (e.g.
protected Runnable	nextTask() Create next task wrapped in a Runnable.
<C extends TimerDrivenModuleContext,T extends TimerDrivenModule<C>> void	registerModuleAndContext(T module, C context) Register a module and its context.
void	start() Start scheduling tasks / delegating work to registered modules.
void	stop() Stop scheduling tasks.

Methods inherited from class java.lang.Object

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

Constructor Detail

RotatingTaskScheduler

public RotatingTaskScheduler(org.neo4j.graphdb.GraphDatabaseService database,
                             ModuleMetadataRepository repository,
                             TimingStrategy timingStrategy)

Construct a new task scheduler.

Parameters:

database - against which the modules are running.

repository - for persisting metadata.

timingStrategy - strategy for timing the work delegation.

Method Detail

registerModuleAndContext

public <C extends TimerDrivenModuleContext,T extends TimerDrivenModule<C>> void registerModuleAndContext(T module,
                                                                                                         C context)

Register a module and its context. Registered modules will be delegated to and contexts managed by the implementation of this interface after the first registration. Must be called before TaskScheduler.start().

Specified by:

registerModuleAndContext in interface TaskScheduler

Type Parameters:

C - type of the metadata.

T - type of the module.

Parameters:

module - to register.

context - of the module.

start

public void start()

Start scheduling tasks / delegating work to registered modules.

Specified by:

start in interface TaskScheduler

stop

public void stop()

Stop scheduling tasks. Perform cleanup. No other methods should be called afterwards as this object will be useless.

Specified by:

stop in interface TaskScheduler

nextTask

protected Runnable nextTask()

Create next task wrapped in a Runnable. The Runnable schedules the next task when finished.

Returns:

next task to be run wrapped in a Runnable.

hasCorrectRole

protected boolean hasCorrectRole(TimerDrivenModule<?> module)

Check if the given module has the correct role (e.g. master or slave) to run.

Parameters:

module - to check for.

Returns:

true iff can run.