Package com.lmax.disruptor.dsl

Interface EventProcessorFactory<T>

Type Parameters:
T - implementation storing the data for sharing during exchange or parallel coordination of an event.
public interface EventProcessorFactory<T>
A factory interface to make it possible to include custom event processors in a chain: 

 disruptor.handleEventsWith(handler1).then((ringBuffer, barrierSequences) -> new CustomEventProcessor(ringBuffer, barrierSequences));

  • Method Details

    • createEventProcessor

      EventProcessor createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
      Create a new event processor that gates on barrierSequences.
      Parameters:
      ringBuffer - the ring buffer to receive events from.
      barrierSequences - the sequences to gate on
      Returns:
      a new EventProcessor that gates on barrierSequences before processing events