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 boolean
private final SequenceBarrier
private 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:
getSequences
in interfaceConsumerInfo
-
getBarrier
- Specified by:
getBarrier
in interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()- Specified by:
isEndOfChain
in interfaceConsumerInfo
-
start
- Specified by:
start
in interfaceConsumerInfo
-
halt
public void halt()- Specified by:
halt
in interfaceConsumerInfo
-
markAsUsedInBarrier
public void markAsUsedInBarrier()- Specified by:
markAsUsedInBarrier
in interfaceConsumerInfo
-
isRunning
public boolean isRunning()- Specified by:
isRunning
in interfaceConsumerInfo
-