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 | Method and Description |
---|---|
<A> void |
EventSink.publishEvent(EventTranslatorOneArg<E,A> translator,
A arg0)
Allows one user supplied argument.
|
<A> void |
RingBuffer.publishEvent(EventTranslatorOneArg<E,A> translator,
A arg0) |
<A> void |
EventSink.publishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0)
Allows one user supplied argument per event.
|
<A> void |
RingBuffer.publishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0) |
<A> void |
EventSink.publishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0)
Allows one user supplied argument per event.
|
<A> void |
RingBuffer.publishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0) |
private <A> void |
RingBuffer.translateAndPublish(EventTranslatorOneArg<E,A> translator,
long sequence,
A arg0) |
private <A> void |
RingBuffer.translateAndPublishBatch(EventTranslatorOneArg<E,A> translator,
A[] arg0,
int batchStartsAt,
int batchSize,
long finalSequence) |
<A> boolean |
EventSink.tryPublishEvent(EventTranslatorOneArg<E,A> translator,
A arg0)
Allows one user supplied argument.
|
<A> boolean |
RingBuffer.tryPublishEvent(EventTranslatorOneArg<E,A> translator,
A arg0) |
<A> boolean |
EventSink.tryPublishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0)
Allows one user supplied argument.
|
<A> boolean |
RingBuffer.tryPublishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0) |
<A> boolean |
EventSink.tryPublishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0)
Allows one user supplied argument.
|
<A> boolean |
RingBuffer.tryPublishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0) |
Modifier and Type | Method and Description |
---|---|
<A> void |
Disruptor.publishEvent(EventTranslatorOneArg<T,A> eventTranslator,
A arg)
Publish an event to the ring buffer.
|
<A> void |
Disruptor.publishEvents(EventTranslatorOneArg<T,A> eventTranslator,
A[] arg)
Publish a batch of events to the ring buffer.
|