public interface SequenceBarrier
EventProcessor
s for processing a data structureModifier and Type | Method | 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, InterruptedException, TimeoutException
sequence
- to wait forAlertException
- if a status change has occurred for the DisruptorInterruptedException
- 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.Copyright © 2019. All rights reserved.