/openjdk7/jdk/test/java/util/concurrent/LinkedBlockingQueue/ |
H A D | ToArray.java | 36 Collection<Integer> c = new LinkedBlockingQueue<Integer>();
|
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | PollMemoryLeak.java | 48 new LinkedBlockingQueue(10),
|
H A D | OfferDrainToLoops.java | 61 test(new LinkedBlockingQueue()); 62 test(new LinkedBlockingQueue(2000));
|
H A D | CancelledProducerConsumerLoops.java | 125 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
|
H A D | Interrupt.java | 121 testQueue(new LinkedBlockingQueue<Object>(1));
|
H A D | LastElement.java | 36 testQueue(new LinkedBlockingQueue<Integer>());
|
H A D | MultipleProducersSingleConsumerLoops.java | 92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), producers, iters);
|
H A D | ProducerConsumerLoops.java | 92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
|
H A D | SingleProducerMultipleConsumerLoops.java | 78 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), consumers, iters);
|
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/ |
H A D | LdapRequest.java | 30 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 D | ScanDirAgent.java | 47 import java.util.concurrent.LinkedBlockingQueue; 104 queue = new LinkedBlockingQueue<Notification>();
|
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/ |
H A D | IteratorWeakConsistency.java | 47 test(new LinkedBlockingQueue()); 48 test(new LinkedBlockingQueue(20));
|
H A D | OfferRemoveLoops.java | 52 testQueue(new LinkedBlockingQueue(10)); 53 testQueue(new LinkedBlockingQueue());
|
H A D | GCRetention.java | 46 import java.util.concurrent.LinkedBlockingQueue; 70 queues.add(new LinkedBlockingQueue<Boolean>());
|
H A D | RemovePollRace.java | 48 import java.util.concurrent.LinkedBlockingQueue; 70 queues.add(new LinkedBlockingQueue<Boolean>());
|
/openjdk7/jdk/test/java/lang/management/ManagementFactory/ |
H A D | GetObjectName.java | 40 import java.util.concurrent.LinkedBlockingQueue;
|
/openjdk7/jdk/test/java/util/PriorityQueue/ |
H A D | RemoveContains.java | 70 test(new LinkedBlockingQueue<String>(10));
|
H A D | NoNulls.java | 50 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 D | ExecutorCompletionService.java | 141 * {@link LinkedBlockingQueue} as a completion queue. 152 this.completionQueue = new LinkedBlockingQueue<Future<V>>();
|
H A D | Executors.java | 91 new LinkedBlockingQueue<Runnable>()); 116 new LinkedBlockingQueue<Runnable>(), 137 new LinkedBlockingQueue<Runnable>())); 158 new LinkedBlockingQueue<Runnable>(),
|
H A D | LinkedBlockingQueue.java | 78 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 D | DirectoryScannerTest.java | 53 import java.util.concurrent.LinkedBlockingQueue; 98 final LinkedBlockingQueue<Notification> queue = 99 new LinkedBlockingQueue<Notification>(); 203 new LinkedBlockingQueue<Notification>();
|
H A D | ScanManagerTest.java | 43 import java.util.concurrent.LinkedBlockingQueue; 176 final LinkedBlockingQueue<Notification> queue = 177 new LinkedBlockingQueue<Notification>();
|
/openjdk7/jdk/test/java/util/Collection/ |
H A D | BiggernYours.java | 202 new LinkedBlockingQueue(), 203 new LinkedBlockingQueue() {
|
H A D | IteratorAtEnd.java | 49 testCollection(new LinkedBlockingQueue());
|