public interface SequenceBarrier
EventProcessor
s for processing a data structureModifier and Type | Method and Description |
---|---|
void |
alert()
Alert the
EventProcessor s of a status change and stay in this status until cleared. |
void |
checkAlert()
Check if an alert has been raised and throw an
AlertException if it has. |
void |
clearAlert()
Clear the current alert status.
|
long |
getCursor()
Get the current cursor value that can be read.
|
boolean |
isAlerted()
The current alert status for the barrier.
|
long |
waitFor(long sequence)
Wait for the given sequence to be available for consumption.
|
long waitFor(long sequence) throws AlertException, java.lang.InterruptedException, TimeoutException
sequence
- to wait forAlertException
- if a status change has occurred for the Disruptorjava.lang.InterruptedException
- if the thread needs awaking on a condition variable.TimeoutException
long getCursor()
boolean isAlerted()
void alert()
EventProcessor
s of a status change and stay in this status until cleared.void clearAlert()
void checkAlert() throws AlertException
AlertException
if it has.AlertException
- if alert has been raised.