Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
Modifier and Type | Class and Description |
---|---|
class |
RingBuffer<E>
Ring based store of reusable entries containing the data representing
an event being exchanged between event producer and
EventProcessor s. |
Constructor and Description |
---|
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<T> eventHandler)
Construct a
EventProcessor that will automatically track the progress by updating its sequence when
the EventHandler.onEvent(Object, long, boolean) method returns. |
Copyright © 2018. All rights reserved.