Package nz.org.riskscape.engine.sched

Class Worker

java.lang.Object

nz.org.riskscape.engine.sched.Worker

All Implemented Interfaces:

Runnable

public class Worker
extends Object
implements Runnable

The Worker represents a thread that can run tasks. It gets assigned a WorkerTask by the Scheduler and runs the task until it is either complete, there's no more input available, or its output buffer is full. The result of the task is then passed back to the Scheduler.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Worker.Result

Field Summary

Fields

Modifier and Type	Field	Description
final AtomicReference<Worker.Result>	lastResult
static final int	MAX_WAIT_MILLISECS
final Scheduler	owner

Constructor Summary

Constructors

Constructor	Description
Worker(int id, Scheduler owner)

Method Summary

Modifier and Type	Method	Description
Worker.Result	clearLastTask()
boolean	isRunning()
void	run()
void	runTask(WorkerTask toRun)
void	setCurrentTask(WorkerTask task)
void	stop()	Stop the Worker (once it completes any task currently in progress).
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

lastResult

public final AtomicReference<Worker.Result> lastResult

owner

public final Scheduler owner

MAX_WAIT_MILLISECS

public static final int MAX_WAIT_MILLISECS

See Also:

• Constant Field Values

Constructor Details

Worker

public Worker(int id,
 Scheduler owner)

Method Details

isRunning

public boolean isRunning()

Returns:

true if the Worker is currently busy running a task

clearLastTask

public Worker.Result clearLastTask()

setCurrentTask

public void setCurrentTask(WorkerTask task)

runTask

public void runTask(WorkerTask toRun)

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

Stop the Worker (once it completes any task currently in progress).

toString

public String toString()

Overrides:

toString in class Object