org.apache.oodt.cas.workflow.engine

Class TaskQuerier

java.lang.Object

org.apache.oodt.cas.workflow.engine.TaskQuerier

All Implemented Interfaces:

Runnable

public class TaskQuerier
extends Object
implements Runnable

The purpose of this class is to constantly pop off tasks that are run to run and made available by the WorkflowProcessorQueue, and then to set their state to Executing (running Category), so they will be picked up on the next WorkflowState change, and end up executing.

Version:

$Revision$

Author:

mattmann, bfoster

Constructor Summary

Constructors

Constructor and Description
TaskQuerier(WorkflowProcessorQueue processorQueue, PrioritySorter prioritizer, WorkflowInstanceRepository repo, long waitSeconds) Constructs a new TaskQuerier with the given WorkflowProcessorQueue, and with the associated PrioritySorter which acts as a sorter of the runnable WorkflowProcessors.

Method Summary

Modifier and Type	Method and Description
TaskProcessor	getNext() Gets the next available TaskProcessor from the List of runnableProcessors.
List<WorkflowProcessor>	getRunnableProcessors()
boolean	isRunning()
void	run() Marches through the set of processors that are currently in the Processor queue, checks to see if they are NOT in the done state, or if they are currently in the holding state.
void	setRunning(boolean running)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskQuerier

public TaskQuerier(WorkflowProcessorQueue processorQueue,
                   PrioritySorter prioritizer,
                   WorkflowInstanceRepository repo,
                   long waitSeconds)

Constructs a new TaskQuerier with the given WorkflowProcessorQueue, and with the associated PrioritySorter which acts as a sorter of the runnable WorkflowProcessors.

Parameters:

processorQueue - The associated set of queued Workflow Tasks.

prioritizer - The prioritizer to use to sort the ready-to-run Workflow Tasks.

repo - The WorkflowInstanceRepository to save the state of WorkflowInstances.

waitSeconds - The default amount of seconds to wait while dispositioning processors

Method Detail

run

public void run()

Marches through the set of processors that are currently in the Processor queue, checks to see if they are NOT in the done state, or if they are currently in the holding state. If either of those are true, the processor is popped off the queue, and then added to the runnableProcessors list (in a synchronized fashion), and then their state is set to Executing (category, running). Finally the runnableProcessors list is sorted according to the given prioritizer.

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

getRunnableProcessors

public List<WorkflowProcessor> getRunnableProcessors()

Returns:

the runnableProcessors

getNext

public TaskProcessor getNext()

Gets the next available TaskProcessor from the List of runnableProcessors. Removes that TaskProcessor from the actual runnableProcessors List.

Returns:

The next available TaskProcessor from the List of runnableProcessors.