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, take
int getOfferReserve()
TaskWorker getOfferTask()
boolean offer(M value, long timeout, java.util.concurrent.TimeUnit unit, int reservedSpace)