Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
com.lmax.disruptor.dsl | |
com.lmax.disruptor.util |
Modifier and Type | Class and Description |
---|---|
class |
BatchEventProcessor<T>
Convenience class for handling the batching semantics of consuming entries from a
RingBuffer
and delegating the available events to an EventHandler . |
class |
NoOpEventProcessor
No operation version of a
EventProcessor that simply tracks a Sequence . |
class |
WorkProcessor<T>
A
WorkProcessor wraps a single WorkHandler , effectively consuming the sequence
and ensuring appropriate barriers. |
Modifier and Type | Field and Description |
---|---|
private EventProcessor |
EventProcessorInfo.eventprocessor |
Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessorFactory.createEventProcessor(RingBuffer<T> ringBuffer,
Sequence[] barrierSequences)
Create a new event processor that gates on
barrierSequences . |
EventProcessor |
EventProcessorInfo.getEventProcessor() |
EventProcessor |
ConsumerRepository.getEventProcessorFor(EventHandler<T> handler) |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerRepository.add(EventProcessor processor) |
void |
ConsumerRepository.add(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
EventHandlerGroup<T> |
Disruptor.after(EventProcessor... processors)
Create a group of event processors to be used as a dependency.
|
EventHandlerGroup<T> |
EventHandlerGroup.and(EventProcessor... processors)
Create a new event handler group that combines the handlers in this group with processors.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventProcessor... processors)
Set up custom event processors to handle events from the ring buffer.
|
Constructor and Description |
---|
EventProcessorInfo(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
Modifier and Type | Method and Description |
---|---|
static Sequence[] |
Util.getSequencesFor(EventProcessor... processors)
Get an array of
Sequence s for the passed EventProcessor s |