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 boolean
endOfChain
private SequenceBarrier
sequenceBarrier
private 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 SequenceBarrier
getBarrier()
Sequence[]
getSequences()
void
halt()
boolean
isEndOfChain()
boolean
isRunning()
void
markAsUsedInBarrier()
void
start(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:
getSequences
in interfaceConsumerInfo
-
getBarrier
public SequenceBarrier getBarrier()
- Specified by:
getBarrier
in interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()
- Specified by:
isEndOfChain
in interfaceConsumerInfo
-
start
public void start(java.util.concurrent.Executor executor)
- 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
-
-