public class ExecutorBasedOverseer extends AbstractOverseer implements DefeatableOverseer
Modifier and Type | Field and Description |
---|---|
private ExecutorService |
executor |
currentWorkers, observers, taskWorkerMapping, workersSetMutex
Constructor and Description |
---|
ExecutorBasedOverseer(ExecutorService executor)
Constructor.
|
ExecutorBasedOverseer(int poolSize) |
ExecutorBasedOverseer(int poolSize,
ThreadFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected Worker |
createWorker(Task task) |
void |
shutdown()
Shuts down the overseers resources.
|
protected void |
startWorker(Worker worker) |
addObserver, getTaskState, getTaskStates, getWorker, removeObserver, reportTaskFinished, reportTaskThrowedException, startTask
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addObserver, getTaskState, getTaskStates, getWorker, removeObserver, startTask
reportTaskFinished, reportTaskThrowedException
private ExecutorService executor
public ExecutorBasedOverseer(int poolSize)
public ExecutorBasedOverseer(int poolSize, ThreadFactory factory)
public ExecutorBasedOverseer(ExecutorService executor)
shutdown()
method closes the
given executor service.executor
- protected Worker createWorker(Task task)
createWorker
in class AbstractOverseer
protected void startWorker(Worker worker)
startWorker
in class AbstractOverseer
public void shutdown()
DefeatableOverseer
shutdown
in interface DefeatableOverseer
Copyright © 2015. All rights reserved.