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