com.lmax.disruptor
Interface EventProcessor

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

BatchEventProcessor, NoOpEventProcessor, WorkProcessor

public interface EventProcessor
extends java.lang.Runnable

EventProcessors waitFor events to become available for consumption from the RingBuffer An EventProcessor will be associated with a Thread for execution.

Method Summary

Sequence	getSequence() Get a reference to the Sequence being used by this EventProcessor.
void	halt() Signal that this EventProcessor should stop when it has finished consuming at the next clean break.

Methods inherited from interface java.lang.Runnable

run

Method Detail

getSequence

Sequence getSequence()

Get a reference to the Sequence being used by this EventProcessor.

Returns:

reference to the Sequence for this EventProcessor

halt

void halt()

Signal that this EventProcessor should stop when it has finished consuming at the next clean break. It will call SequenceBarrier.alert() to notify the thread to check status.