Package com.lmax.disruptor
Interface EventProcessor
-
- All Superinterfaces:
java.lang.Runnable
- All Known Implementing Classes:
BatchEventProcessor,NoOpEventProcessor,WorkProcessor
public interface EventProcessor extends java.lang.RunnableEventProcessors waitFor events to become available for consumption from theRingBufferAn EventProcessor will generally be associated with a Thread for execution.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description SequencegetSequence()Get a reference to theSequencebeing used by thisEventProcessor.voidhalt()Signal that this EventProcessor should stop when it has finished consuming at the next clean break.booleanisRunning()
-
-
-
Method Detail
-
getSequence
Sequence getSequence()
Get a reference to theSequencebeing used by thisEventProcessor.- Returns:
- reference to the
Sequencefor thisEventProcessor
-
halt
void halt()
Signal that this EventProcessor should stop when it has finished consuming at the next clean break. It will callSequenceBarrier.alert()to notify the thread to check status.
-
isRunning
boolean isRunning()
-
-