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

/libcore/jsr166-tests/src/test/java/jsr166/
H A DConcurrentLinkedQueueTest.java16 import java.util.concurrent.ConcurrentLinkedQueue;
37 private ConcurrentLinkedQueue<Integer> populatedQueue(int n) {
38 ConcurrentLinkedQueue<Integer> q = new ConcurrentLinkedQueue<Integer>();
51 assertEquals(0, new ConcurrentLinkedQueue().size());
59 new ConcurrentLinkedQueue((Collection)null);
69 new ConcurrentLinkedQueue(Arrays.asList(new Integer[SIZE]));
82 new ConcurrentLinkedQueue(Arrays.asList(ints));
94 ConcurrentLinkedQueue q = new ConcurrentLinkedQueue(Array
[all...]
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DConcurrentLinkedQueue.java62 * A {@code ConcurrentLinkedQueue} is an appropriate choice when
97 * {@code ConcurrentLinkedQueue}
100 * the {@code ConcurrentLinkedQueue} in another thread.
106 public class ConcurrentLinkedQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,Queue,java.io.Serializable
237 * Creates a {@code ConcurrentLinkedQueue} that is initially empty.
239 public ConcurrentLinkedQueue() { method in class:ConcurrentLinkedQueue
244 * Creates a {@code ConcurrentLinkedQueue}
252 public ConcurrentLinkedQueue(Collection<? extends E> c) { method in class:ConcurrentLinkedQueue
817 final ConcurrentLinkedQueue<E> queue;
821 CLQSpliterator(ConcurrentLinkedQueue<
[all...]
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DCollectionAndMapModifyStreamTest.java30 import java.util.concurrent.ConcurrentLinkedQueue;
86 collections.add(new ConcurrentLinkedQueue<>(content));
/libcore/ojluni/src/main/java/sun/nio/ch/
H A DAsynchronousChannelGroupImpl.java79 taskQueue = new ConcurrentLinkedQueue<Runnable>();

Completed in 410 milliseconds