public interface ActorQueue<M>
extends java.util.concurrent.BlockingQueue<M>
| Modifier and Type | Method and Description |
|---|---|
int |
getOfferReserve() |
TaskWorker |
getOfferTask() |
boolean |
offer(M value,
long timeout,
java.util.concurrent.TimeUnit unit,
int reservedSpace) |
add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, takeint getOfferReserve()
TaskWorker getOfferTask()
boolean offer(M value, long timeout, java.util.concurrent.TimeUnit unit, int reservedSpace)