org.dice_research.topicmodeling.concurrent.overseers.pool

Class ExecutorBasedOverseer

java.lang.Object

org.dice_research.topicmodeling.concurrent.overseers.AbstractOverseer

org.dice_research.topicmodeling.concurrent.overseers.pool.ExecutorBasedOverseer

All Implemented Interfaces:

Overseer, DefeatableOverseer, WorkerObserver

public class ExecutorBasedOverseer
extends AbstractOverseer
implements DefeatableOverseer

Field Summary

Fields

Modifier and Type	Field and Description
private ExecutorService	executor

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

currentWorkers, observers, taskWorkerMapping, workersSetMutex

Constructor Summary

Constructors

Constructor and Description
ExecutorBasedOverseer(ExecutorService executor) Constructor.
ExecutorBasedOverseer(int poolSize)
ExecutorBasedOverseer(int poolSize, ThreadFactory factory)

Method Summary

Modifier and Type	Method and Description
protected Worker	createWorker(Task task)
void	shutdown() Shuts down the overseers resources.
protected void	startWorker(Worker worker)

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

addObserver, getTaskState, getTaskStates, getWorker, removeObserver, reportTaskFinished, reportTaskThrowedException, startTask

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.dice_research.topicmodeling.concurrent.overseers.Overseer

addObserver, getTaskState, getTaskStates, getWorker, removeObserver, startTask

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

reportTaskFinished, reportTaskThrowedException

Field Detail

executor

private ExecutorService executor

Constructor Detail

ExecutorBasedOverseer

public ExecutorBasedOverseer(int poolSize)

ExecutorBasedOverseer

public ExecutorBasedOverseer(int poolSize,
                             ThreadFactory factory)

ExecutorBasedOverseer

public ExecutorBasedOverseer(ExecutorService executor)

Constructor. Note that calling the shutdown() method closes the given executor service.

Parameters:

executor -

Method Detail

createWorker

protected Worker createWorker(Task task)

Specified by:

createWorker in class AbstractOverseer

startWorker

protected void startWorker(Worker worker)

Specified by:

startWorker in class AbstractOverseer

shutdown

public void shutdown()

Description copied from interface: DefeatableOverseer

Shuts down the overseers resources.

Specified by:

shutdown in interface DefeatableOverseer