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 | Method and Description |
---|---|
<A,B> void |
EventSink.publishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1)
Allows two user supplied arguments.
|
<A,B> void |
RingBuffer.publishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1) |
<A,B> void |
EventSink.publishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> void |
RingBuffer.publishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1) |
<A,B> void |
EventSink.publishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> void |
RingBuffer.publishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1) |
private <A,B> void |
RingBuffer.translateAndPublish(EventTranslatorTwoArg<E,A,B> translator,
long sequence,
A arg0,
B arg1) |
private <A,B> void |
RingBuffer.translateAndPublishBatch(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1,
int batchStartsAt,
int batchSize,
long finalSequence) |
<A,B> boolean |
EventSink.tryPublishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1)
Allows two user supplied arguments.
|
<A,B> boolean |
RingBuffer.tryPublishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1) |
<A,B> boolean |
EventSink.tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> boolean |
RingBuffer.tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1) |
<A,B> boolean |
EventSink.tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> boolean |
RingBuffer.tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1) |