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 |
Modifier and Type | Interface and Description |
---|---|
interface |
SequenceReportingEventHandler<T>
Used by the
BatchEventProcessor to set a callback allowing the EventHandler to notify
when it has finished consuming an event if this happens after the onEvent(Object, long, boolean) call. |
Modifier and Type | Class and Description |
---|---|
class |
AggregateEventHandler<T>
An aggregate collection of
EventHandler s that get called in sequence for each event. |
Constructor and Description |
---|
AggregateEventHandler(EventHandler<T>... eventHandlers)
Construct an aggregate collection of
EventHandler s to be called in sequence. |
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<T> eventHandler)
Construct a
EventProcessor that will automatically track the progress by updating its sequence when
the onEvent(Object, long, boolean) method returns. |
Modifier and Type | Method and Description |
---|---|
EventHandlerGroup<T> |
Disruptor.after(EventHandler<T>... handlers)
Create a group of event handlers to be used as a dependency.
|
SequenceBarrier |
Disruptor.getBarrierFor(EventHandler<T> handler)
Get the
SequenceBarrier used by a specific handler. |
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventHandler<T>... handlers)
Set up event handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWith(EventHandler<T>... handlers)
Set up batch handlers to handle events from the ring buffer.
|
ExceptionHandlerSetting<?> |
Disruptor.handleExceptionsFor(EventHandler<T> eventHandler)
Override the default exception handler for a specific handler.
|
EventHandlerGroup<T> |
EventHandlerGroup.then(EventHandler<T>... handlers)
Set up batch handlers to consume events from the ring buffer.
|
Copyright © 2018. All rights reserved.