org.dice_research.topicmodeling.concurrent.overseers

Class AbstractOverseer

java.lang.Object

org.dice_research.topicmodeling.concurrent.overseers.AbstractOverseer

All Implemented Interfaces:

Overseer, WorkerObserver

Direct Known Subclasses:

ExecutorBasedOverseer, SimpleOverseer

public abstract class AbstractOverseer
extends Object
implements Overseer

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<Worker>	currentWorkers
private static org.slf4j.Logger	LOGGER
protected List<TaskObserver>	observers
protected Map<Task,Worker>	taskWorkerMapping
protected Semaphore	workersSetMutex

Constructor Summary

Constructors

Constructor and Description
AbstractOverseer()

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.
protected abstract Worker	createWorker(Task task)
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.
protected abstract void	startWorker(Worker worker)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

currentWorkers

protected Set<Worker> currentWorkers

taskWorkerMapping

protected Map<Task,Worker> taskWorkerMapping

workersSetMutex

protected Semaphore workersSetMutex

observers

protected List<TaskObserver> observers

Constructor Detail

AbstractOverseer

public AbstractOverseer()

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

createWorker

protected abstract Worker createWorker(Task task)

startWorker

protected abstract void startWorker(Worker worker)

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

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

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