edu.iu.harp.schstatic

Class StaticScheduler<I,O,T extends Task<I,O>>

java.lang.Object

edu.iu.harp.schstatic.StaticScheduler<I,O,T>

public class StaticScheduler<I,O,T extends Task<I,O>>
extends java.lang.Object

The static scheduler

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Constructor and Description
StaticScheduler(java.util.List<T> tasks)

Method Summary

Modifier and Type	Method and Description
void	cleanInputQueue() Clean the queue of input
T	getTask(int taskID) Get the Task by its ID
boolean	hasError(int taskID) Check if has errors on this task
boolean	hasOutput(int taskID) Check if has a new output
void	pause() Pause the scheduling
void	start() Start to schedule tasks
void	stop() Stop scheduling
void	submit(int taskID, I input) Submit the input to task
O	waitForOutput(int taskID) Blocked and wait for output.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

Constructor Detail

StaticScheduler

public StaticScheduler(java.util.List<T> tasks)

Method Detail

getTask

public T getTask(int taskID)

Get the Task by its ID

Parameters:

taskID - the ID of the task

Returns:

the Task

submit

public void submit(int taskID,
                   I input)

Submit the input to task

Parameters:

taskID - the ID of the task

input - the input

start

public void start()

Start to schedule tasks

pause

public void pause()

Pause the scheduling

cleanInputQueue

public void cleanInputQueue()

Clean the queue of input

stop

public void stop()

Stop scheduling

waitForOutput

public O waitForOutput(int taskID)

Blocked and wait for output. Invoke as while(hasOutput()) { waitForOutput(); }

Returns:

the output

hasOutput

public boolean hasOutput(int taskID)

Check if has a new output

Parameters:

taskID - the ID of the task

Returns:

true if has a new output, false otherwise

hasError

public boolean hasError(int taskID)

Check if has errors on this task

Parameters:

taskID - the ID of the task

Returns:

true if has errors, false otherwise