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 | 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 | Description |
---|---|---|
class |
AggregateEventHandler<T> |
An aggregate collection of
EventHandler s that get called in sequence for each event. |
Constructor | Description |
---|---|
AggregateEventHandler(EventHandler<T>... eventHandlers) |
Construct an aggregate collection of
EventHandler s to be called in sequence. |
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<? super 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 | 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. |
long |
Disruptor.getSequenceValueFor(EventHandler<T> b1) |
Gets the sequence value for the specified event handlers.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventHandler<? super T>... handlers) |
Set up event handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWith(EventHandler<? super T>... handlers) |
Set up batch handlers to handle events from the ring buffer.
|
ExceptionHandlerSetting<T> |
Disruptor.handleExceptionsFor(EventHandler<T> eventHandler) |
Override the default exception handler for a specific handler.
|
EventHandlerGroup<T> |
EventHandlerGroup.then(EventHandler<? super T>... handlers) |
Set up batch handlers to consume events from the ring buffer.
|
Copyright © 2019. All rights reserved.