public interface EventProcessor
extends java.lang.Runnable
RingBuffer
An EventProcessor will generally be associated with a Thread for execution.
Modifier and Type | Method and Description |
---|---|
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.
|
boolean |
isRunning() |
Sequence getSequence()
Sequence
being used by this EventProcessor
.Sequence
for this EventProcessor
void halt()
SequenceBarrier.alert()
to notify the thread to check status.boolean isRunning()