|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use EventProcessor | |
|---|---|
| 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 | |
| Uses of EventProcessor in com.lmax.disruptor |
|---|
| Classes in com.lmax.disruptor that implement EventProcessor | |
|---|---|
class |
BatchEventProcessor<T>
Convenience class for handling the batching semantics of consuming entries from a RingBuffer
and delegating the available events to a EventHandler. |
class |
NoOpEventProcessor
No operation version of a EventProcessor that simply tracks a Sequencer. |
class |
WorkProcessor<T>
WorkProcessor for ensuring each sequence is handled by only a single processor, effectively consuming the sequence. |
| Uses of EventProcessor in com.lmax.disruptor.dsl |
|---|
| Methods in com.lmax.disruptor.dsl with parameters of type EventProcessor | |
|---|---|
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 handleEventException events from the ring buffer. |
| Uses of EventProcessor in com.lmax.disruptor.util |
|---|
| Methods in com.lmax.disruptor.util with parameters of type EventProcessor | |
|---|---|
static Sequence[] |
Util.getSequencesFor(EventProcessor... processors)
Get an array of Sequences for the passed EventProcessors |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||