Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 – 25 of 56) sorted by relevance

123

/libcore/jsr166-tests/src/test/java/jsr166/
DBlockingQueueTest.java18 import java.util.concurrent.BlockingQueue;
52 protected abstract BlockingQueue emptyCollection(); in emptyCollection()
92 final BlockingQueue q = emptyCollection(); in testTimedOfferNull()
105 final BlockingQueue q = emptyCollection();
150 final BlockingQueue q = emptyCollection();
161 final BlockingQueue q = emptyCollection();
172 final BlockingQueue q = emptyCollection();
183 final BlockingQueue q = emptyCollection();
194 final BlockingQueue q = emptyCollection();
216 final BlockingQueue q = emptyCollection(); in testTimedPollWithOffer()
[all …]
DSynchronousQueueFairTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedTransferQueueBlockingQueueTest.java11 import java.util.concurrent.BlockingQueue;
17 protected BlockingQueue emptyCollection() { in emptyCollection()
DPriorityBlockingQueueGenericTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedBlockingQueueUnboundedTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedBlockingDequeUnboundedTest.java9 import java.util.concurrent.BlockingQueue;
14 protected BlockingQueue emptyCollection() { in emptyCollection()
DSynchronousQueueNotFairTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedBlockingDequeBoundedTest.java9 import java.util.concurrent.BlockingQueue;
14 protected BlockingQueue emptyCollection() { in emptyCollection()
DPriorityBlockingQueueInitialCapacityTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedBlockingQueueBoundedTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DArrayBlockingQueueFairTest.java12 import java.util.concurrent.BlockingQueue;
21 protected BlockingQueue emptyCollection() { in emptyCollection()
DArrayBlockingQueueNonFairTest.java12 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DBlockingQueueTest.java52 import java.util.concurrent.BlockingQueue;
84 protected abstract BlockingQueue emptyCollection(); in emptyCollection()
127 final BlockingQueue q = emptyCollection(); in testTimedOfferNull()
141 final BlockingQueue q = emptyCollection();
190 final BlockingQueue q = emptyCollection();
202 final BlockingQueue q = emptyCollection();
214 final BlockingQueue q = emptyCollection();
226 final BlockingQueue q = emptyCollection();
238 final BlockingQueue q = emptyCollection();
261 final BlockingQueue q = emptyCollection(); in testTimedPollWithOffer()
[all …]
DLinkedBlockingQueueTest.java53 import java.util.concurrent.BlockingQueue;
70 protected BlockingQueue emptyCollection() { in emptyCollection()
78 protected BlockingQueue emptyCollection() { in emptyCollection()
215 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
443 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
519 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DPriorityBlockingQueueTest.java54 import java.util.concurrent.BlockingQueue;
71 protected BlockingQueue emptyCollection() { in emptyCollection()
79 protected BlockingQueue emptyCollection() { in emptyCollection()
239 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
475 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DCollection8Test.java60 import java.util.concurrent.BlockingQueue;
191 if (c instanceof BlockingQueue) {
192 BlockingQueue q = (BlockingQueue) c;
239 if (c instanceof BlockingQueue) {
240 BlockingQueue q = (BlockingQueue) c;
DArrayBlockingQueueTest.java55 import java.util.concurrent.BlockingQueue;
98 protected BlockingQueue emptyCollection() { in emptyCollection()
106 protected BlockingQueue emptyCollection() { in emptyCollection()
244 BlockingQueue q = populatedQueue(0, 2, 2, false); in testEmptyFull()
261 BlockingQueue q = populatedQueue(size, size, 2 * size, false); in testRemainingCapacity()
569 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DLinkedTransferQueueTest.java53 import java.util.concurrent.BlockingQueue;
71 protected BlockingQueue emptyCollection() { in emptyCollection()
176 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
264 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
342 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
370 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testTimedPollAfterInterrupt()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java108 private final BlockingQueue<Future<V>> completionQueue;
115 BlockingQueue<Future<V>> completionQueue) { in QueueingFuture()
121 private final BlockingQueue<Future<V>> completionQueue;
170 BlockingQueue<Future<V>> completionQueue) { in ExecutorCompletionService()
DThreadPoolExecutor.java460 private final BlockingQueue<Runnable> workQueue;
869 BlockingQueue<Runnable> q = workQueue; in drainQueue()
1208 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor()
1243 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1279 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1316 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1775 public BlockingQueue<Runnable> getQueue() { in getQueue()
1812 final BlockingQueue<Runnable> q = workQueue; in purge()
DTransferQueue.java68 public interface TransferQueue<E> extends BlockingQueue<E> {
DBlockingQueue.java179 public interface BlockingQueue<E> extends Queue<E> { interface
DBlockingDeque.java198 public interface BlockingDeque<E> extends BlockingQueue<E>, Deque<E> {
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DThreadPoolExecutor.java48 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue) { in ThreadPoolExecutor()
57 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor()
67 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor()
77 java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, in ThreadPoolExecutor()
273 public java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue() { in getQueue()
387 private final java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue;
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DDelayQueue.annotated.java40 …rent.Delayed> extends java.util.AbstractQueue<E> implements java.util.concurrent.BlockingQueue<E> {

123