edu.iu.harp.schdynamic

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

java.lang.Object

edu.iu.harp.schdynamic.DynamicScheduler<I,O,T>

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

The dynamic scheduler

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	cleanInputQueue() Clean the input queue
java.util.List<T>	getTasks() Get the list of tasks
boolean	hasError() Check if has errors or not
boolean	hasOutput() Check if has a new output
void	pause() Pause the task
void	pauseNow() Pause the task immediately
void	start() Start scheduling
void	stop() Stop submission Send stop signal to the queue based on the number of tasks
void	submit(I input) Submit the input
void	submitAll(java.util.Collection<I> inputs) Submit a collection of inputs
void	submitAll(I[] inputs) Submit an array of inputs
O	waitForOutput() Blocked and wait for outputs Invoke as while(hasOutput()) { waitForOutput(); }

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

DynamicScheduler

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

Method Detail

getTasks

public java.util.List<T> getTasks()

Get the list of tasks

Returns:

the list of tasks

submit

public void submit(I input)

Submit the input

Parameters:

input - the input

submitAll

public void submitAll(java.util.Collection<I> inputs)

Submit a collection of inputs

Parameters:

inputs - a collection of inputs

submitAll

public void submitAll(I[] inputs)

Submit an array of inputs

Parameters:

inputs - an aray of inputs

start

public void start()

Start scheduling

pause

public void pause()

Pause the task

pauseNow

public void pauseNow()

Pause the task immediately

cleanInputQueue

public void cleanInputQueue()

Clean the input queue

stop

public void stop()

Stop submission Send stop signal to the queue based on the number of tasks

waitForOutput

public O waitForOutput()

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

Returns:

the output

hasOutput

public boolean hasOutput()

Check if has a new output

Returns:

true if has a new output, false otherwise

hasError

public boolean hasError()

Check if has errors or not

Returns:

true if has errors, false otherwise