org.dice_research.topicmodeling.concurrent.overseers

Interface Overseer

All Superinterfaces:

WorkerObserver

All Known Subinterfaces:

DefeatableOverseer, OverseerDecorator

All Known Implementing Classes:

AbstractOverseer, AbstractOverseerDecorator, BlockingOverseer, ExecutorBasedOverseer, SimpleOverseer

public interface Overseer
extends WorkerObserver

The Overseer manages the assignment of Tasks to Workers.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Method Summary

Modifier and Type	Method and Description
void	addObserver(TaskObserver observer) Adds the given TaskObserver to the list of observers of this Overseer and is notified if the state of a task changes.
TaskState	getTaskState(Task task) Returns the state of the given Task.
TaskState[]	getTaskStates() Returns the state of all Tasks managed by this Overseer.
Worker	getWorker(Task task) Returns the Worker instance that is assigned to the given task.
void	removeObserver(TaskObserver observer) Removes the given TaskObserver from the list of observers if it exists.
void	startTask(Task task) Starts the given Task.

Methods inherited from interface org.dice_research.topicmodeling.concurrent.workers.WorkerObserver

reportTaskFinished, reportTaskThrowedException

Method Detail

startTask

void startTask(Task task)

Starts the given Task.

Parameters:

task - the Task that should be executed

getTaskState

TaskState getTaskState(Task task)

Returns the state of the given Task.

Parameters:

task - the Task of which the state should be returned

Returns:

the state of the given Task

getTaskStates

TaskState[] getTaskStates()

Returns the state of all Tasks managed by this Overseer.

Returns:

the state of all Tasks managed by this Overseer

addObserver

void addObserver(TaskObserver observer)

Adds the given TaskObserver to the list of observers of this Overseer and is notified if the state of a task changes.

Parameters:

observer - the TaskObserver that should be a able to observe the Tasks managed by this overseer

removeObserver

void removeObserver(TaskObserver observer)

Removes the given TaskObserver from the list of observers if it exists.

Parameters:

observer - the TaskObserver that should be removed

getWorker

Worker getWorker(Task task)

Returns the Worker instance that is assigned to the given task.

Parameters:

task - the task that is performed by the worker

Returns:

the worker or null if the given task is not known