Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 – 25 of 54) 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()
DLinkedBlockingQueueUnboundedTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DPriorityBlockingQueueGenericTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DSynchronousQueueNotFairTest.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()
DLinkedTransferQueueBlockingQueueTest.java11 import java.util.concurrent.BlockingQueue;
17 protected BlockingQueue emptyCollection() { in emptyCollection()
DArrayBlockingQueueFairTest.java12 import java.util.concurrent.BlockingQueue;
21 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()
DLinkedBlockingQueueBoundedTest.java11 import java.util.concurrent.BlockingQueue;
16 protected BlockingQueue emptyCollection() { in emptyCollection()
DPriorityBlockingQueueInitialCapacityTest.java11 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.java109 private final BlockingQueue<Future<V>> completionQueue;
116 BlockingQueue<Future<V>> completionQueue) { in QueueingFuture()
122 private final BlockingQueue<Future<V>> completionQueue;
171 BlockingQueue<Future<V>> completionQueue) { in ExecutorCompletionService()
DThreadPoolExecutor.java466 private final BlockingQueue<Runnable> workQueue;
877 BlockingQueue<Runnable> q = workQueue; in drainQueue()
1219 BlockingQueue<Runnable> workQueue) { in ThreadPoolExecutor()
1253 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1288 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1325 BlockingQueue<Runnable> workQueue, in ThreadPoolExecutor()
1764 public BlockingQueue<Runnable> getQueue() { in getQueue()
1801 final BlockingQueue<Runnable> q = workQueue; in purge()
DTransferQueue.java68 public interface TransferQueue<E> extends BlockingQueue<E> {
DBlockingQueue.java181 public interface BlockingQueue<E> extends Queue<E> { interface
DBlockingDeque.java207 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