Runnable
BatchEventProcessor
, NoOpEventProcessor
, WorkProcessor
public interface EventProcessor extends Runnable
RingBuffer
An EventProcessor will generally be associated with a Thread for execution.
Modifier and Type | Method | 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()
Copyright © 2019. All rights reserved.