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 |
---|---|
void |
EventSink.publishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args)
Allows a variable number of user supplied arguments
|
void |
RingBuffer.publishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args) |
void |
EventSink.publishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
void |
RingBuffer.publishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args) |
void |
EventSink.publishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
void |
RingBuffer.publishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args) |
private void |
RingBuffer.translateAndPublish(EventTranslatorVararg<E> translator,
long sequence,
java.lang.Object... args) |
private void |
RingBuffer.translateAndPublishBatch(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
long finalSequence,
java.lang.Object[][] args) |
boolean |
EventSink.tryPublishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args)
Allows a variable number of user supplied arguments
|
boolean |
RingBuffer.tryPublishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args) |
boolean |
EventSink.tryPublishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
boolean |
RingBuffer.tryPublishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args) |
boolean |
EventSink.tryPublishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
boolean |
RingBuffer.tryPublishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args) |