Uses of Interface
com.lmax.disruptor.EventFactory
Packages that use EventFactory
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of EventFactory in com.lmax.disruptor
Methods in com.lmax.disruptor with parameters of type EventFactoryModifier and TypeMethodDescriptionstatic <E> RingBuffer
<E> RingBuffer.create
(ProducerType producerType, EventFactory<E> factory, int bufferSize, WaitStrategy waitStrategy) Create a new Ring Buffer with the specified producer type (SINGLE or MULTI)static <E> RingBuffer
<E> RingBuffer.createMultiProducer
(EventFactory<E> factory, int bufferSize) Create a new multiple producer RingBuffer using the default wait strategyBlockingWaitStrategy
.static <E> RingBuffer
<E> RingBuffer.createMultiProducer
(EventFactory<E> factory, int bufferSize, WaitStrategy waitStrategy) Create a new multiple producer RingBuffer with the specified wait strategy.static <E> RingBuffer
<E> RingBuffer.createSingleProducer
(EventFactory<E> factory, int bufferSize) Create a new single producer RingBuffer using the default wait strategyBlockingWaitStrategy
.static <E> RingBuffer
<E> RingBuffer.createSingleProducer
(EventFactory<E> factory, int bufferSize, WaitStrategy waitStrategy) Create a new single producer RingBuffer with the specified wait strategy.private void
RingBufferFields.fill
(EventFactory<E> eventFactory) Constructors in com.lmax.disruptor with parameters of type EventFactoryModifierConstructorDescription(package private)
RingBuffer
(EventFactory<E> eventFactory, Sequencer sequencer) Construct a RingBuffer with the full option set.(package private)
RingBufferFields
(EventFactory<E> eventFactory, Sequencer sequencer) WorkerPool
(EventFactory<T> eventFactory, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers) Construct a work pool with an internalRingBuffer
for convenience. -
Uses of EventFactory in com.lmax.disruptor.dsl
Constructors in com.lmax.disruptor.dsl with parameters of type EventFactoryModifierConstructorDescriptionDisruptor
(EventFactory<T> eventFactory, int ringBufferSize, Executor executor) Deprecated.Disruptor
(EventFactory<T> eventFactory, int ringBufferSize, Executor executor, ProducerType producerType, WaitStrategy waitStrategy) Deprecated.Use aThreadFactory
instead of anExecutor
as a the ThreadFactory is able to report errors when it is unable to construct a thread to run a producer.Disruptor
(EventFactory<T> eventFactory, int ringBufferSize, ThreadFactory threadFactory) Create a new Disruptor.Disruptor
(EventFactory<T> eventFactory, int ringBufferSize, ThreadFactory threadFactory, ProducerType producerType, WaitStrategy waitStrategy) Create a new Disruptor.
ThreadFactory
instead of anExecutor
as a the ThreadFactory is able to report errors when it is unable to construct a thread to run a producer.