Package com.lmax.disruptor.dsl
Class WorkerPoolInfo<T>
java.lang.Object
com.lmax.disruptor.dsl.WorkerPoolInfo<T>
- All Implemented Interfaces:
ConsumerInfo
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate booleanprivate final SequenceBarrierprivate final WorkerPool<T> -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
workerPool
-
sequenceBarrier
-
endOfChain
private boolean endOfChain
-
-
Constructor Details
-
WorkerPoolInfo
WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
-
-
Method Details
-
getSequences
- Specified by:
getSequencesin interfaceConsumerInfo
-
getBarrier
- Specified by:
getBarrierin interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()- Specified by:
isEndOfChainin interfaceConsumerInfo
-
start
- 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
-