Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 – 25 of 55) 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 …]
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()
DSynchronousQueueFairTest.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()
DLinkedBlockingQueueUnboundedTest.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()
DPriorityBlockingQueueInitialCapacityTest.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()
DArrayBlockingQueueNonFairTest.java12 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DLinkedTransferQueueTest.java19 import java.util.concurrent.BlockingQueue;
136 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
218 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
292 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
319 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testTimedPollAfterInterrupt()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DBlockingQueueTest.java44 import java.util.concurrent.BlockingQueue;
76 protected abstract BlockingQueue emptyCollection(); in emptyCollection()
116 final BlockingQueue q = emptyCollection(); in testTimedOfferNull()
129 final BlockingQueue q = emptyCollection();
174 final BlockingQueue q = emptyCollection();
185 final BlockingQueue q = emptyCollection();
196 final BlockingQueue q = emptyCollection();
207 final BlockingQueue q = emptyCollection();
218 final BlockingQueue q = emptyCollection();
240 final BlockingQueue q = emptyCollection(); in testTimedPollWithOffer()
[all …]
DLinkedBlockingQueueTest.java45 import java.util.concurrent.BlockingQueue;
56 protected BlockingQueue emptyCollection() { in emptyCollection()
62 protected BlockingQueue emptyCollection() { in emptyCollection()
188 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
404 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
476 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DPriorityBlockingQueueTest.java46 import java.util.concurrent.BlockingQueue;
57 protected BlockingQueue emptyCollection() { in emptyCollection()
63 protected BlockingQueue emptyCollection() { in emptyCollection()
211 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
432 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DCollection8Test.java52 import java.util.concurrent.BlockingQueue;
182 if (c instanceof BlockingQueue) {
183 BlockingQueue q = (BlockingQueue) c;
230 if (c instanceof BlockingQueue) {
231 BlockingQueue q = (BlockingQueue) c;
DLinkedTransferQueueTest.java45 import java.util.concurrent.BlockingQueue;
57 protected BlockingQueue emptyCollection() { in emptyCollection()
154 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
236 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
310 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
337 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testTimedPollAfterInterrupt()
DArrayBlockingQueueTest.java47 import java.util.concurrent.BlockingQueue;
81 protected BlockingQueue emptyCollection() { in emptyCollection()
87 protected BlockingQueue emptyCollection() { in emptyCollection()
217 BlockingQueue q = populatedQueue(0, 2, 2, false); in testEmptyFull()
233 BlockingQueue q = populatedQueue(size, size, 2 * size, false); in testRemainingCapacity()
525 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java106 private final BlockingQueue<Future<V>> completionQueue;
113 BlockingQueue<Future<V>> completionQueue) { in QueueingFuture()
119 private final BlockingQueue<Future<V>> completionQueue;
168 BlockingQueue<Future<V>> completionQueue) { in ExecutorCompletionService()
DThreadPoolExecutor.java459 private final BlockingQueue<Runnable> workQueue;
860 BlockingQueue<Runnable> q = workQueue; in drainQueue()
1197 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor()
1232 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1268 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1305 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1757 public BlockingQueue<Runnable> getQueue() { in getQueue()
1794 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;

123