@InterfaceAudience.Private public class StealJobQueue<T> extends PriorityBlockingQueue<T>
| Constructor and Description |
|---|
StealJobQueue() |
StealJobQueue(int initCapacity,
int stealFromQueueInitCapacity) |
| Modifier and Type | Method and Description |
|---|---|
BlockingQueue<T> |
getStealFromQueue()
Get a queue whose job might be stolen by the consumer of this original queue
|
boolean |
offer(T t) |
T |
poll(long timeout,
TimeUnit unit) |
T |
take() |
add, clear, comparator, contains, drainTo, drainTo, iterator, offer, peek, poll, put, remainingCapacity, remove, size, toArray, toArray, toStringaddAll, element, removecontainsAll, isEmpty, removeAll, retainAllclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAllpublic StealJobQueue()
public StealJobQueue(int initCapacity,
int stealFromQueueInitCapacity)
public BlockingQueue<T> getStealFromQueue()
public boolean offer(T t)
offer in interface BlockingQueue<T>offer in interface Queue<T>offer in class PriorityBlockingQueue<T>public T take() throws InterruptedException
take in interface BlockingQueue<T>take in class PriorityBlockingQueue<T>InterruptedExceptionpublic T poll(long timeout, TimeUnit unit) throws InterruptedException
poll in interface BlockingQueue<T>poll in class PriorityBlockingQueue<T>InterruptedExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.