Package com.lmax.disruptor.dsl
Class WorkerPoolInfo<T>
- java.lang.Object
-
- com.lmax.disruptor.dsl.WorkerPoolInfo<T>
-
- All Implemented Interfaces:
ConsumerInfo
class WorkerPoolInfo<T> extends java.lang.Object implements ConsumerInfo
-
-
Field Summary
Fields Modifier and Type Field Description private booleanendOfChainprivate SequenceBarriersequenceBarrierprivate WorkerPool<T>workerPool
-
Constructor Summary
Constructors Constructor Description WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SequenceBarriergetBarrier()Sequence[]getSequences()voidhalt()booleanisEndOfChain()booleanisRunning()voidmarkAsUsedInBarrier()voidstart(java.util.concurrent.Executor executor)
-
-
-
Field Detail
-
workerPool
private final WorkerPool<T> workerPool
-
sequenceBarrier
private final SequenceBarrier sequenceBarrier
-
endOfChain
private boolean endOfChain
-
-
Constructor Detail
-
WorkerPoolInfo
WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
-
-
Method Detail
-
getSequences
public Sequence[] getSequences()
- Specified by:
getSequencesin interfaceConsumerInfo
-
getBarrier
public SequenceBarrier getBarrier()
- Specified by:
getBarrierin interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()
- Specified by:
isEndOfChainin interfaceConsumerInfo
-
start
public void start(java.util.concurrent.Executor executor)
- Specified by:
startin interfaceConsumerInfo
-
halt
public void halt()
- Specified by:
haltin interfaceConsumerInfo
-
markAsUsedInBarrier
public void markAsUsedInBarrier()
- Specified by:
markAsUsedInBarrierin interfaceConsumerInfo
-
isRunning
public boolean isRunning()
- Specified by:
isRunningin interfaceConsumerInfo
-
-