class WorkerPoolInfo<T> extends java.lang.Object implements ConsumerInfo
Modifier and Type | Field and Description |
---|---|
private boolean |
endOfChain |
private SequenceBarrier |
sequenceBarrier |
private WorkerPool<T> |
workerPool |
Constructor and Description |
---|
WorkerPoolInfo(WorkerPool<T> workerPool,
SequenceBarrier sequenceBarrier) |
Modifier and Type | Method and Description |
---|---|
SequenceBarrier |
getBarrier() |
Sequence[] |
getSequences() |
void |
halt() |
boolean |
isEndOfChain() |
boolean |
isRunning() |
void |
markAsUsedInBarrier() |
void |
start(java.util.concurrent.Executor executor) |
private final WorkerPool<T> workerPool
private final SequenceBarrier sequenceBarrier
private boolean endOfChain
public WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
public Sequence[] getSequences()
getSequences
in interface ConsumerInfo
public SequenceBarrier getBarrier()
getBarrier
in interface ConsumerInfo
public boolean isEndOfChain()
isEndOfChain
in interface ConsumerInfo
public void start(java.util.concurrent.Executor executor)
start
in interface ConsumerInfo
public void halt()
halt
in interface ConsumerInfo
public void markAsUsedInBarrier()
markAsUsedInBarrier
in interface ConsumerInfo
public boolean isRunning()
isRunning
in interface ConsumerInfo