Searched refs:ConcurrentLinkedQueue (Results 1 - 17 of 17) sorted by relevance

/openjdk7/jaxws/src/share/jaxws_classes/com/sun/istack/internal/
H A DPool.java28 import java.util.concurrent.ConcurrentLinkedQueue;
53 * Default implementation that uses {@link ConcurrentLinkedQueue}
58 * Don't rely on the fact that this class extends from {@link ConcurrentLinkedQueue}.
62 private volatile WeakReference<ConcurrentLinkedQueue<T>> queue;
88 private ConcurrentLinkedQueue<T> getQueue() {
89 WeakReference<ConcurrentLinkedQueue<T>> q = queue;
91 ConcurrentLinkedQueue<T> d = q.get();
97 ConcurrentLinkedQueue<T> d = new ConcurrentLinkedQueue<T>();
98 queue = new WeakReference<ConcurrentLinkedQueue<
[all...]
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/util/
H A DPool.java33 import java.util.concurrent.ConcurrentLinkedQueue;
53 private volatile WeakReference<ConcurrentLinkedQueue<T>> queue;
71 private ConcurrentLinkedQueue<T> getQueue() {
72 WeakReference<ConcurrentLinkedQueue<T>> q = queue;
74 ConcurrentLinkedQueue<T> d = q.get();
80 ConcurrentLinkedQueue<T> d = new ConcurrentLinkedQueue<T>();
81 queue = new WeakReference<ConcurrentLinkedQueue<T>>(d);
/openjdk7/jdk/test/javax/imageio/stream/StreamCloserLeak/testapp/
H A DMain.java31 import java.util.concurrent.ConcurrentLinkedQueue;
43 private final ConcurrentLinkedQueue<Throwable> problems;
45 public Main(String uniq, ConcurrentLinkedQueue<Throwable> p) {
74 private ConcurrentLinkedQueue<Throwable> problems;
76 ConcurrentLinkedQueue<Throwable> p) throws IOException
/openjdk7/jdk/test/javax/imageio/stream/StreamCloserLeak/test/
H A DMain.java39 import java.util.concurrent.ConcurrentLinkedQueue;
56 private static ConcurrentLinkedQueue<Throwable> problems =
57 new ConcurrentLinkedQueue<Throwable>();
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DConcurrentLinkedQueue.java54 * A {@code ConcurrentLinkedQueue} is an appropriate choice when
89 * {@code ConcurrentLinkedQueue}
92 * the {@code ConcurrentLinkedQueue} in another thread.
103 public class ConcurrentLinkedQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,Queue,java.io.Serializable
252 * Creates a {@code ConcurrentLinkedQueue} that is initially empty.
254 public ConcurrentLinkedQueue() { method in class:ConcurrentLinkedQueue
259 * Creates a {@code ConcurrentLinkedQueue}
267 public ConcurrentLinkedQueue(Collection<? extends E> c) { method in class:ConcurrentLinkedQueue
826 Class k = ConcurrentLinkedQueue.class;
/openjdk7/jdk/test/java/util/concurrent/ConcurrentQueues/
H A DIteratorWeakConsistency.java52 test(new ConcurrentLinkedQueue());
H A DGCRetention.java44 import java.util.concurrent.ConcurrentLinkedQueue;
67 queues.add(new ConcurrentLinkedQueue<Boolean>());
H A DRemovePollRace.java45 import java.util.concurrent.ConcurrentLinkedQueue;
67 queues.add(new ConcurrentLinkedQueue<Boolean>());
H A DOfferRemoveLoops.java59 testQueue(new ConcurrentLinkedQueue());
H A DConcurrentQueueLoops.java59 queues.add(new ConcurrentLinkedQueue<Integer>());
/openjdk7/jdk/test/java/util/Collection/
H A DBiggernYours.java192 new ConcurrentLinkedQueue(),
193 new ConcurrentLinkedQueue() {
H A DIteratorAtEnd.java52 testCollection(new ConcurrentLinkedQueue());
H A DMOAT.java81 testCollection(new ConcurrentLinkedQueue<Integer>());
440 (q instanceof ConcurrentLinkedQueue)) {
/openjdk7/jdk/src/share/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/
H A DScanManager.java61 import java.util.concurrent.ConcurrentLinkedQueue;
743 private final ConcurrentLinkedQueue<SessionTask> tasklist =
744 new ConcurrentLinkedQueue<SessionTask>();
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DAsynchronousChannelGroupImpl.java79 taskQueue = new ConcurrentLinkedQueue<Runnable>();
/openjdk7/jdk/test/java/util/Collections/
H A DRacingCollections.java238 list.add(new ConcurrentLinkedQueue<Integer>());
/openjdk7/jdk/make/java/java/
H A DFILES_java.gmk290 java/util/concurrent/ConcurrentLinkedQueue.java \

Completed in 622 milliseconds