Package com.lmax.disruptor
Interface EventProcessor
-
- All Superinterfaces:
Runnable
- All Known Implementing Classes:
BatchEventProcessor
,NoOpEventProcessor
,WorkProcessor
public interface EventProcessor extends Runnable
EventProcessors waitFor events to become available for consumption from theRingBuffer
An EventProcessor will generally be associated with a Thread for execution.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Sequence
getSequence()
Get a reference to theSequence
being used by thisEventProcessor
.void
halt()
Signal that this EventProcessor should stop when it has finished consuming at the next clean break.boolean
isRunning()
-
-
-
Method Detail
-
getSequence
Sequence getSequence()
Get a reference to theSequence
being used by thisEventProcessor
.- Returns:
- reference to the
Sequence
for 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()
-
-