D | ConditionPriorityBlockingQueue.java | 123 public T poll() { in poll() method in ConditionPriorityBlockingQueue 124 return poll(new AlwaysMatch<T>()); in poll() 134 public T poll(IMatcher<T> matcher) { in poll() method in ConditionPriorityBlockingQueue 165 public T poll(long timeout, TimeUnit unit) throws InterruptedException { in poll() method in ConditionPriorityBlockingQueue 166 return poll(timeout, unit, new AlwaysMatch<T>()); in poll() 180 public T poll(long timeout, TimeUnit unit, IMatcher<T> matcher) throws InterruptedException { in poll() method in ConditionPriorityBlockingQueue 207 while ((matchedObj = poll(matcher)) == null && (nanos == null || nanos > 0)) { in blockingPoll() 392 T removedObj = poll(matcher); in addUnique()
|