org.dice_research.topicmodeling.concurrent.overseers.decorator

Class AbstractOverseerDecorator

java.lang.Object

org.dice_research.topicmodeling.concurrent.overseers.decorator.AbstractOverseerDecorator

All Implemented Interfaces:

OverseerDecorator, Overseer, WorkerObserver

public class AbstractOverseerDecorator
extends Object
implements OverseerDecorator

Field Summary

Fields

Modifier and Type	Field and Description
private Overseer	overseer

Constructor Summary

Constructors

Constructor and Description
AbstractOverseerDecorator(Overseer overseer)

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.
Overseer	getDecorated()
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	reportTaskFinished(Worker worker)
void	reportTaskThrowedException(Worker worker, Throwable t)
void	startTask(Task task) Starts the given Task.

Methods inherited from class java.lang.Object

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

Field Detail

overseer

private Overseer overseer

Constructor Detail

AbstractOverseerDecorator

public AbstractOverseerDecorator(Overseer overseer)

Method Detail

startTask

public void startTask(Task task)

Description copied from interface: Overseer

Starts the given Task.

Specified by:

startTask in interface Overseer

Parameters:

task - the Task that should be executed

addObserver

public void addObserver(TaskObserver observer)

Description copied from interface: Overseer

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

Specified by:

addObserver in interface Overseer

Parameters:

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

removeObserver

public void removeObserver(TaskObserver observer)

Description copied from interface: Overseer

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

Specified by:

removeObserver in interface Overseer

Parameters:

observer - the TaskObserver that should be removed

reportTaskFinished

public void reportTaskFinished(Worker worker)

Specified by:

reportTaskFinished in interface WorkerObserver

reportTaskThrowedException

public void reportTaskThrowedException(Worker worker,
                                       Throwable t)

Specified by:

reportTaskThrowedException in interface WorkerObserver

getDecorated

public Overseer getDecorated()

Specified by:

getDecorated in interface OverseerDecorator

getTaskState

public TaskState getTaskState(Task task)

Description copied from interface: Overseer

Returns the state of the given Task.

Specified by:

getTaskState in interface Overseer

Parameters:

task - the Task of which the state should be returned

Returns:

the state of the given Task

getTaskStates

public TaskState[] getTaskStates()

Description copied from interface: Overseer

Returns the state of all Tasks managed by this Overseer.

Specified by:

getTaskStates in interface Overseer

Returns:

the state of all Tasks managed by this Overseer

getWorker

public Worker getWorker(Task task)

Description copied from interface: Overseer

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

Specified by:

getWorker in interface Overseer

Parameters:

task - the task that is performed by the worker

Returns:

the worker or null if the given task is not known