org.trianacode.taskgraph.service

Class Scheduler

java.lang.Object

org.trianacode.taskgraph.service.Scheduler

All Implemented Interfaces:

SchedulerInterface

public class Scheduler
extends java.lang.Object
implements SchedulerInterface

The scheduler is responsible for waking-up all the input tasks in a taskgraph when the taskgraph is run.

Field Summary

Fields

Modifier and Type	Field and Description
StampedeLog	stampedeLog

Constructor Summary

Constructors

Constructor and Description
Scheduler(TaskGraph taskgraph) Construct a scheduler for the given taskgraph and registers it with all the tasks in the taskgraph

Method Summary

Methods

Modifier and Type	Method and Description
void	addExecutionListener(ExecutionListener listener)
void	flushTaskGraph() Flushes all data from the task graph cables
ExecutionState	getExecutionState()
void	notifyError(RunnableInstance cause, java.lang.String message) Called to notify an error has occured in the taskgraph
void	pauseTaskGraph() Pauses the taskgraph
void	removeExecutionListener(ExecutionListener listener)
void	resetTaskGraph() Halt the taskgraph and reset all units to their start values.
void	resumeTaskGraph() Continue after a pause.
void	runTask(Task task) Runs the specified task (within a running taskgraph)
void	runTaskGraph() Runs the main taskgraph
void	runTaskGraph(HistoryClipIn history) Runs the taskgraph by waking up all the input tasks.
void	setExecutionProperties(java.util.HashMap<java.lang.String,java.lang.String> executionProperties)
void	wakeTask(Task task) Wakes up the specfied task within a running taskgraph

Methods inherited from class java.lang.Object

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

Field Detail

stampedeLog

public StampedeLog stampedeLog

Constructor Detail

Scheduler

public Scheduler(TaskGraph taskgraph)

Construct a scheduler for the given taskgraph and registers it with all the tasks in the taskgraph

Parameters:

taskgraph -

Method Detail

getExecutionState

public ExecutionState getExecutionState()

Specified by:

getExecutionState in interface SchedulerInterface

Returns:

the taskgraph state

runTaskGraph

public void runTaskGraph()
                  throws SchedulerException

Runs the main taskgraph

Specified by:

runTaskGraph in interface SchedulerInterface

Throws:

SchedulerException

runTaskGraph

public void runTaskGraph(HistoryClipIn history)
                  throws SchedulerException

Runs the taskgraph by waking up all the input tasks. Attaches the specified object as a history clip-in

Specified by:

runTaskGraph in interface SchedulerInterface

Throws:

SchedulerException

pauseTaskGraph

public void pauseTaskGraph()

Pauses the taskgraph

Specified by:

pauseTaskGraph in interface SchedulerInterface

resumeTaskGraph

public void resumeTaskGraph()

Continue after a pause.

Specified by:

resumeTaskGraph in interface SchedulerInterface

resetTaskGraph

public void resetTaskGraph()

Halt the taskgraph and reset all units to their start values.

Specified by:

resetTaskGraph in interface SchedulerInterface

flushTaskGraph

public void flushTaskGraph()

Flushes all data from the task graph cables

Specified by:

flushTaskGraph in interface SchedulerInterface

runTask

public void runTask(Task task)
             throws SchedulerException

Runs the specified task (within a running taskgraph)

Specified by:

runTask in interface SchedulerInterface

Throws:

SchedulerException

notifyError

public void notifyError(RunnableInstance cause,
               java.lang.String message)

Called to notify an error has occured in the taskgraph

Specified by:

notifyError in interface SchedulerInterface

Parameters:

cause - the cause of the error

addExecutionListener

public void addExecutionListener(ExecutionListener listener)

Specified by:

addExecutionListener in interface SchedulerInterface

removeExecutionListener

public void removeExecutionListener(ExecutionListener listener)

Specified by:

removeExecutionListener in interface SchedulerInterface

setExecutionProperties

public void setExecutionProperties(java.util.HashMap<java.lang.String,java.lang.String> executionProperties)

Specified by:

setExecutionProperties in interface SchedulerInterface

wakeTask

public void wakeTask(Task task)

Wakes up the specfied task within a running taskgraph