Uses of Interface
com.lmax.disruptor.EventFactory
-
Packages that use EventFactory 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 -
-
Uses of EventFactory in com.lmax.disruptor
Methods in com.lmax.disruptor with parameters of type EventFactory Modifier and Type Method Description static <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 EventFactory Constructor Description RingBuffer(EventFactory<E> eventFactory, Sequencer sequencer)
Construct a RingBuffer with the full option set.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 EventFactory Constructor Description Disruptor(EventFactory<T> eventFactory, int ringBufferSize, java.util.concurrent.Executor executor)
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, java.util.concurrent.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, java.util.concurrent.ThreadFactory threadFactory)
Create a new Disruptor.Disruptor(EventFactory<T> eventFactory, int ringBufferSize, java.util.concurrent.ThreadFactory threadFactory, ProducerType producerType, WaitStrategy waitStrategy)
Create a new Disruptor.
-