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