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 |
---|---|
private void |
RingBuffer.checkBounds(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize) |
void |
EventSink.publishEvent(EventTranslator<E> translator)
Publishes an event to the ring buffer.
|
void |
RingBuffer.publishEvent(EventTranslator<E> translator) |
void |
EventSink.publishEvents(EventTranslator<E>[] translators)
Publishes multiple events to the ring buffer.
|
void |
RingBuffer.publishEvents(EventTranslator<E>[] translators) |
void |
EventSink.publishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize)
Publishes multiple events to the ring buffer.
|
void |
RingBuffer.publishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize) |
private void |
RingBuffer.translateAndPublish(EventTranslator<E> translator,
long sequence) |
private void |
RingBuffer.translateAndPublishBatch(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize,
long finalSequence) |
boolean |
EventSink.tryPublishEvent(EventTranslator<E> translator)
Attempts to publish an event to the ring buffer.
|
boolean |
RingBuffer.tryPublishEvent(EventTranslator<E> translator) |
boolean |
EventSink.tryPublishEvents(EventTranslator<E>[] translators)
Attempts to publish multiple events to the ring buffer.
|
boolean |
RingBuffer.tryPublishEvents(EventTranslator<E>[] translators) |
boolean |
EventSink.tryPublishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize)
Attempts to publish multiple events to the ring buffer.
|
boolean |
RingBuffer.tryPublishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
void |
Disruptor.publishEvent(EventTranslator<T> eventTranslator)
Publish an event to the ring buffer.
|