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 | Method and Description |
---|---|
EventProcessor |
EventProcessorFactory.createEventProcessor(RingBuffer<T> ringBuffer,
Sequence[] barrierSequences)
Create a new event processor that gates on
barrierSequences . |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static Sequence[] |
Util.getSequencesFor(EventProcessor... processors)
Get an array of
Sequence s for the passed EventProcessor s |
Copyright © 2024. All rights reserved.