Home
last modified time | relevance | path

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

12

/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 …]
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()
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()
DSynchronousQueueFairTest.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()
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()
DArrayBlockingQueueNonFairTest.java12 import java.util.concurrent.BlockingQueue;
16 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()
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()
DLinkedBlockingQueueTest.java19 import java.util.concurrent.BlockingQueue;
158 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
374 final BlockingQueue q = populatedQueue(SIZE); in testBlockingTake()
446 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DThreadPoolExecutorTest.java18 import java.util.concurrent.BlockingQueue;
545 final BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testGetQueue()
577 BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testRemove()
612 final BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testPurge()
748 (BlockingQueue) null); in testConstructorNullPointerException()
819 (BlockingQueue) null, in testConstructorNullPointerException2()
903 (BlockingQueue) null, in testConstructorNullPointerException4()
992 (BlockingQueue) null, in testConstructorNullPointerException6()
DThreadPoolExecutorSubclassTest.java17 import java.util.concurrent.BlockingQueue;
164 BlockingQueue<Runnable> workQueue) { in CustomTPE()
172 BlockingQueue<Runnable> workQueue, in CustomTPE()
182 BlockingQueue<Runnable> workQueue, in CustomTPE()
191 BlockingQueue<Runnable> workQueue, in CustomTPE()
660 final BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testGetQueue()
692 BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testRemove()
727 final BlockingQueue<Runnable> q = new ArrayBlockingQueue<Runnable>(10); in testPurge()
DPriorityBlockingQueueTest.java20 import java.util.concurrent.BlockingQueue;
181 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
399 final BlockingQueue<Integer> q = populatedQueue(SIZE); in testInterruptedTimedPoll()
DDelayQueueTest.java18 import java.util.concurrent.BlockingQueue;
53 protected BlockingQueue emptyCollection() { in emptyCollection()
223 BlockingQueue q = populatedQueue(SIZE); in testRemainingCapacity()
/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()
DTransferQueue.java68 public interface TransferQueue<E> extends BlockingQueue<E> {
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()
DBlockingQueue.java181 public interface BlockingQueue<E> extends Queue<E> { interface
DBlockingDeque.java207 public interface BlockingDeque<E> extends BlockingQueue<E>, Deque<E> {
DScheduledThreadPoolExecutor.java367 BlockingQueue<Runnable> q = super.getQueue(); in onShutdown()
840 public BlockingQueue<Runnable> getQueue() { in getQueue()
850 implements BlockingQueue<Runnable> {
/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;

12