org.dice_research.topicmodeling.concurrent.overseers.simple

Class BlockingOverseer

java.lang.Object

org.dice_research.topicmodeling.concurrent.overseers.AbstractOverseer

org.dice_research.topicmodeling.concurrent.overseers.simple.SimpleOverseer

org.dice_research.topicmodeling.concurrent.overseers.simple.BlockingOverseer

All Implemented Interfaces:

Overseer, WorkerObserver

public class BlockingOverseer
extends SimpleOverseer

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOGGER
private Semaphore	semaphore

Fields inherited from class org.dice_research.topicmodeling.concurrent.overseers.AbstractOverseer

currentWorkers, observers, taskWorkerMapping, workersSetMutex

Constructor Summary

Constructors

Constructor and Description
BlockingOverseer(int numberOfConcurrentTasks)

Method Summary

Modifier and Type	Method and Description
void	reportTaskFinished(Worker worker)
void	reportTaskThrowedException(Worker worker, Throwable t)
void	startTask(Task task) Starts the given Task.

Methods inherited from class org.dice_research.topicmodeling.concurrent.overseers.simple.SimpleOverseer

createWorker, startWorker

Methods inherited from class org.dice_research.topicmodeling.concurrent.overseers.AbstractOverseer

addObserver, getTaskState, getTaskStates, getWorker, removeObserver

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

semaphore

private Semaphore semaphore

Constructor Detail

BlockingOverseer

public BlockingOverseer(int numberOfConcurrentTasks)

Method Detail

startTask

public void startTask(Task task)

Description copied from interface: Overseer

Starts the given Task.

Specified by:

startTask in interface Overseer

Overrides:

startTask in class AbstractOverseer

Parameters:

task - the Task that should be executed

reportTaskFinished

public void reportTaskFinished(Worker worker)

Specified by:

reportTaskFinished in interface WorkerObserver

Overrides:

reportTaskFinished in class AbstractOverseer

reportTaskThrowedException

public void reportTaskThrowedException(Worker worker,
                                       Throwable t)

Specified by:

reportTaskThrowedException in interface WorkerObserver

Overrides:

reportTaskThrowedException in class AbstractOverseer