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() |
wakeboolean 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()