public interface RingBlocker extends TaskWorker
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
isOfferWait() |
boolean |
isPollWait() |
boolean |
offerWait(long tail,
java.util.concurrent.atomic.AtomicLong tailRef,
int reservedSpace,
long timeout,
java.util.concurrent.TimeUnit unit) |
void |
offerWake() |
boolean |
pollWait(long timeout,
java.util.concurrent.TimeUnit unit) |
void |
pollWake() |
wake
boolean offerWait(long tail, java.util.concurrent.atomic.AtomicLong tailRef, int reservedSpace, long timeout, java.util.concurrent.TimeUnit unit)
boolean isOfferWait()
void offerWake()
boolean pollWait(long timeout, java.util.concurrent.TimeUnit unit)
boolean isPollWait()
void pollWake()
void close()