Uses of Interface
com.lmax.disruptor.EventTranslator
Packages that use EventTranslator
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of EventTranslator in com.lmax.disruptor
Methods in com.lmax.disruptor with parameters of type EventTranslatorModifier and TypeMethodDescriptionprivate voidRingBuffer.checkBounds(EventTranslator<E>[] translators, int batchStartsAt, int batchSize) voidEventSink.publishEvent(EventTranslator<E> translator) Publishes an event to the ring buffer.voidRingBuffer.publishEvent(EventTranslator<E> translator) voidEventSink.publishEvents(EventTranslator<E>[] translators) Publishes multiple events to the ring buffer.voidEventSink.publishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize) Publishes multiple events to the ring buffer.voidRingBuffer.publishEvents(EventTranslator<E>[] translators) voidRingBuffer.publishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize) private voidRingBuffer.translateAndPublish(EventTranslator<E> translator, long sequence) private voidRingBuffer.translateAndPublishBatch(EventTranslator<E>[] translators, int batchStartsAt, int batchSize, long finalSequence) booleanEventSink.tryPublishEvent(EventTranslator<E> translator) Attempts to publish an event to the ring buffer.booleanRingBuffer.tryPublishEvent(EventTranslator<E> translator) booleanEventSink.tryPublishEvents(EventTranslator<E>[] translators) Attempts to publish multiple events to the ring buffer.booleanEventSink.tryPublishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize) Attempts to publish multiple events to the ring buffer.booleanRingBuffer.tryPublishEvents(EventTranslator<E>[] translators) booleanRingBuffer.tryPublishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize) -
Uses of EventTranslator in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type EventTranslatorModifier and TypeMethodDescriptionvoidDisruptor.publishEvent(EventTranslator<T> eventTranslator) Publish an event to the ring buffer.