Searched refs:LinkedBlockingDeque (Results 1 - 22 of 22) sorted by relevance

/openjdk7/jdk/src/share/classes/sun/nio/fs/
H A DAbstractWatchService.java39 private final LinkedBlockingDeque<WatchKey> pendingKeys =
40 new LinkedBlockingDeque<WatchKey>();
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DIteratorWeakConsistency.java49 test(new LinkedBlockingDeque());
50 test(new LinkedBlockingDeque(20));
H A DOfferRemoveLoops.java54 testQueue(new LinkedBlockingDeque(10));
55 testQueue(new LinkedBlockingDeque());
H A DGCRetention.java45 import java.util.concurrent.LinkedBlockingDeque;
71 queues.add(new LinkedBlockingDeque<Boolean>());
H A DRemovePollRace.java47 import java.util.concurrent.LinkedBlockingDeque;
71 queues.add(new LinkedBlockingDeque<Boolean>());
H A DConcurrentQueueLoops.java63 queues.add(new LinkedBlockingDeque<Integer>());
/openjdk7/jdk/test/java/util/PriorityQueue/
H A DRemoveContains.java71 test(new LinkedBlockingDeque<String>(10));
H A DNoNulls.java49 import java.util.concurrent.LinkedBlockingDeque;
91 new LinkedBlockingDeque<String>(nullCollection);
138 new LinkedBlockingDeque<String>().add(null);
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DOfferDrainToLoops.java63 test(new LinkedBlockingDeque());
64 test(new LinkedBlockingDeque(2000));
H A DCancelledProducerConsumerLoops.java126 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
H A DInterrupt.java122 testQueue(new LinkedBlockingDeque<Object>(1));
H A DLastElement.java37 testQueue(new LinkedBlockingDeque<Integer>());
H A DMultipleProducersSingleConsumerLoops.java93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), producers, iters);
H A DProducerConsumerLoops.java93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
H A DSingleProducerMultipleConsumerLoops.java79 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), consumers, iters);
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DLinkedBlockingDeque.java74 public class LinkedBlockingDeque<E> class in inherits:AbstractQueue,BlockingDeque,java.io.Serializable
164 * Creates a {@code LinkedBlockingDeque} with a capacity of
167 public LinkedBlockingDeque() { method in class:LinkedBlockingDeque
172 * Creates a {@code LinkedBlockingDeque} with the given (fixed) capacity.
177 public LinkedBlockingDeque(int capacity) { method in class:LinkedBlockingDeque
183 * Creates a {@code LinkedBlockingDeque} with a capacity of
192 public LinkedBlockingDeque(Collection<? extends E> c) { method in class:LinkedBlockingDeque
1040 * Base class for Iterators for LinkedBlockingDeque
1067 final ReentrantLock lock = LinkedBlockingDeque.this.lock;
1101 final ReentrantLock lock = LinkedBlockingDeque
[all...]
/openjdk7/jdk/test/java/util/Collections/
H A DAsLifoQueue.java51 Collections.asLifoQueue(new LinkedBlockingDeque<String>(3));
H A DRacingCollections.java251 list.add(new LinkedBlockingDeque<Integer>(10));
/openjdk7/jdk/test/java/util/Collection/
H A DBiggernYours.java207 new LinkedBlockingDeque(),
208 new LinkedBlockingDeque() {
H A DMOAT.java79 testCollection(new LinkedBlockingDeque<Integer>(20));
438 (q instanceof LinkedBlockingDeque) ||
/openjdk7/jdk/test/java/util/Deque/
H A DChorusLine.java131 deqs.add(new LinkedBlockingDeque<Integer>());
/openjdk7/jdk/make/java/java/
H A DFILES_java.gmk312 java/util/concurrent/LinkedBlockingDeque.java \

Completed in 959 milliseconds