Searched refs:LinkedBlockingQueue (Results 1 - 25 of 36) sorted by relevance

12

/openjdk7/jdk/test/java/util/concurrent/LinkedBlockingQueue/
H A DToArray.java36 Collection<Integer> c = new LinkedBlockingQueue<Integer>();
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DPollMemoryLeak.java48 new LinkedBlockingQueue(10),
H A DOfferDrainToLoops.java61 test(new LinkedBlockingQueue());
62 test(new LinkedBlockingQueue(2000));
H A DCancelledProducerConsumerLoops.java125 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
H A DInterrupt.java121 testQueue(new LinkedBlockingQueue<Object>(1));
H A DLastElement.java36 testQueue(new LinkedBlockingQueue<Integer>());
H A DMultipleProducersSingleConsumerLoops.java92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), producers, iters);
H A DProducerConsumerLoops.java92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
H A DSingleProducerMultipleConsumerLoops.java78 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), consumers, iters);
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/
H A DLdapRequest.java30 import java.util.concurrent.LinkedBlockingQueue;
53 this.replies = new LinkedBlockingQueue<BerDecoder>();
56 new LinkedBlockingQueue<BerDecoder>(replyQueueCapacity);
/openjdk7/jdk/src/share/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/
H A DScanDirAgent.java47 import java.util.concurrent.LinkedBlockingQueue;
104 queue = new LinkedBlockingQueue<Notification>();
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DIteratorWeakConsistency.java47 test(new LinkedBlockingQueue());
48 test(new LinkedBlockingQueue(20));
H A DOfferRemoveLoops.java52 testQueue(new LinkedBlockingQueue(10));
53 testQueue(new LinkedBlockingQueue());
H A DGCRetention.java46 import java.util.concurrent.LinkedBlockingQueue;
70 queues.add(new LinkedBlockingQueue<Boolean>());
H A DRemovePollRace.java48 import java.util.concurrent.LinkedBlockingQueue;
70 queues.add(new LinkedBlockingQueue<Boolean>());
/openjdk7/jdk/test/java/lang/management/ManagementFactory/
H A DGetObjectName.java40 import java.util.concurrent.LinkedBlockingQueue;
/openjdk7/jdk/test/java/util/PriorityQueue/
H A DRemoveContains.java70 test(new LinkedBlockingQueue<String>(10));
H A DNoNulls.java50 import java.util.concurrent.LinkedBlockingQueue;
88 new LinkedBlockingQueue<String>(nullCollection);
135 new LinkedBlockingQueue<String>().add(null);
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DExecutorCompletionService.java141 * {@link LinkedBlockingQueue} as a completion queue.
152 this.completionQueue = new LinkedBlockingQueue<Future<V>>();
H A DExecutors.java91 new LinkedBlockingQueue<Runnable>());
116 new LinkedBlockingQueue<Runnable>(),
137 new LinkedBlockingQueue<Runnable>()));
158 new LinkedBlockingQueue<Runnable>(),
H A DLinkedBlockingQueue.java78 public class LinkedBlockingQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,BlockingQueue,java.io.Serializable
244 * Creates a {@code LinkedBlockingQueue} with a capacity of
247 public LinkedBlockingQueue() { method in class:LinkedBlockingQueue
252 * Creates a {@code LinkedBlockingQueue} with the given (fixed) capacity.
258 public LinkedBlockingQueue(int capacity) { method in class:LinkedBlockingQueue
265 * Creates a {@code LinkedBlockingQueue} with a capacity of
274 public LinkedBlockingQueue(Collection<? extends E> c) { method in class:LinkedBlockingQueue
/openjdk7/jdk/src/share/sample/jmx/jmx-scandir/test/com/sun/jmx/examples/scandir/
H A DDirectoryScannerTest.java53 import java.util.concurrent.LinkedBlockingQueue;
98 final LinkedBlockingQueue<Notification> queue =
99 new LinkedBlockingQueue<Notification>();
203 new LinkedBlockingQueue<Notification>();
H A DScanManagerTest.java43 import java.util.concurrent.LinkedBlockingQueue;
176 final LinkedBlockingQueue<Notification> queue =
177 new LinkedBlockingQueue<Notification>();
/openjdk7/jdk/test/java/util/Collection/
H A DBiggernYours.java202 new LinkedBlockingQueue(),
203 new LinkedBlockingQueue() {
H A DIteratorAtEnd.java49 testCollection(new LinkedBlockingQueue());

Completed in 128 milliseconds

12