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 and Description
private boolean	endOfChain
private SequenceBarrier	sequenceBarrier
private WorkerPool<T>	workerPool

Constructor Summary

Constructors

Constructor and Description
WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

workerPool

private final WorkerPool<T> workerPool

sequenceBarrier

private final SequenceBarrier sequenceBarrier

endOfChain

private boolean endOfChain

Constructor Detail

WorkerPoolInfo

public WorkerPoolInfo(WorkerPool<T> workerPool,
                      SequenceBarrier sequenceBarrier)

Method Detail

getSequences

public Sequence[] getSequences()

Specified by:

getSequences in interface ConsumerInfo

getBarrier

public SequenceBarrier getBarrier()

Specified by:

getBarrier in interface ConsumerInfo

isEndOfChain

public boolean isEndOfChain()

Specified by:

isEndOfChain in interface ConsumerInfo

start

public void start(java.util.concurrent.Executor executor)

Specified by:

start in interface ConsumerInfo

halt

public void halt()

Specified by:

halt in interface ConsumerInfo

markAsUsedInBarrier

public void markAsUsedInBarrier()

Specified by:

markAsUsedInBarrier in interface ConsumerInfo

isRunning

public boolean isRunning()

Specified by:

isRunning in interface ConsumerInfo