org.apache.oodt.cas.workflow.engine

Class TaskRunner

java.lang.Object

org.apache.oodt.cas.workflow.engine.TaskRunner

All Implemented Interfaces:

Runnable

public class TaskRunner
extends Object
implements Runnable

Implements the TaskRunner framework. Acts as a thread that works with the TaskQuerier to take the next sorted (aka ones that have been sorted with the Workflow PrioritySorter) task and then leverage the Engine's Runner to execute the task. The TaskRunner thread first pops a task off the list using TaskQuerier.getNext() and then so long as the thread's runner has open slots as returned by , and is false and isRunning() is true, then the task is handed off to the runner for execution. The TaskRunner thread can be paused during which time it waits seconds, wakes up to see if it's unpaused, and then goes back to sleep if not, otherwise, resumes executing if it was unpaused.

Since:

Apache OODT 0.5

Version:

$Revision$

Author:

mattmann, bfoster

Constructor Summary

Constructors

Constructor and Description
TaskRunner(TaskQuerier taskQuerier, EngineRunner runner)

Method Summary

Modifier and Type	Method and Description
protected WorkflowTask	extractTaskFromProcessor(TaskProcessor taskProcessor)
boolean	isRunning()
void	run()
void	setRunning(boolean running)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRunner

public TaskRunner(TaskQuerier taskQuerier,
                  EngineRunner runner)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

isRunning

public boolean isRunning()

Returns:

the running

setRunning

public void setRunning(boolean running)

Parameters:

running - the running to set

extractTaskFromProcessor

protected WorkflowTask extractTaskFromProcessor(TaskProcessor taskProcessor)