Home
last modified time | relevance | path

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

/libcore/ojluni/src/test/java/util/concurrent/tck/
DLinkedBlockingQueueTest.java49 import java.util.concurrent.LinkedBlockingQueue;
57 return new LinkedBlockingQueue(); in emptyCollection()
63 return new LinkedBlockingQueue(SIZE); in emptyCollection()
73 public Class<?> klazz() { return LinkedBlockingQueue.class; } in suite()
74 public Collection emptyCollection() { return new LinkedBlockingQueue(); } in suite()
89 private LinkedBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
90 LinkedBlockingQueue<Integer> q = in populatedQueue()
91 new LinkedBlockingQueue<Integer>(n); in populatedQueue()
107 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
108 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity()); in testConstructor1()
[all …]
DLinkedBlockingQueue8Test.java36 import java.util.concurrent.LinkedBlockingQueue;
56 () -> new LinkedBlockingQueue().spliterator().getComparator()); in testSpliterator_getComparator()
63 LinkedBlockingQueue q = new LinkedBlockingQueue(); in testSpliterator_characteristics()
DThreadPoolExecutorSubclassTest.java51 import java.util.concurrent.LinkedBlockingQueue;
1947 new LinkedBlockingQueue<Runnable>(),
2033 new LinkedBlockingQueue<Runnable>());
DThreadPoolExecutorTest.java53 import java.util.concurrent.LinkedBlockingQueue;
1949 new LinkedBlockingQueue<Runnable>(),
2064 new LinkedBlockingQueue<Runnable>());
/libcore/jsr166-tests/src/test/java/jsr166/
DLinkedBlockingQueueTest.java23 import java.util.concurrent.LinkedBlockingQueue;
60 private LinkedBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
61 LinkedBlockingQueue<Integer> q = in populatedQueue()
62 new LinkedBlockingQueue<Integer>(n); in populatedQueue()
77 assertEquals(SIZE, new LinkedBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
78 assertEquals(Integer.MAX_VALUE, new LinkedBlockingQueue().remainingCapacity()); in testConstructor1()
86 new LinkedBlockingQueue(0); in testConstructor2()
96 new LinkedBlockingQueue(null); in testConstructor3()
107 new LinkedBlockingQueue(elements); in testConstructor4()
122 new LinkedBlockingQueue(elements); in testConstructor5()
[all …]
DLinkedBlockingQueueUnboundedTest.java12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue(); in emptyCollection()
DLinkedBlockingQueueBoundedTest.java12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue(SIZE); in emptyCollection()
DThreadPoolExecutorSubclassTest.java26 import java.util.concurrent.LinkedBlockingQueue;
1925 new LinkedBlockingQueue<Runnable>(),
2011 new LinkedBlockingQueue<Runnable>());
DThreadPoolExecutorTest.java27 import java.util.concurrent.LinkedBlockingQueue;
1932 new LinkedBlockingQueue<Runnable>(),
2047 new LinkedBlockingQueue<Runnable>());
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DLinkedBlockingQueue.java41 public class LinkedBlockingQueue<E> extends java.util.AbstractQueue<E> class
44 public LinkedBlockingQueue() { in LinkedBlockingQueue() method in LinkedBlockingQueue
48 public LinkedBlockingQueue(int capacity) { in LinkedBlockingQueue() method in LinkedBlockingQueue
52 public LinkedBlockingQueue(java.util.Collection<? extends E> c) { in LinkedBlockingQueue() method in LinkedBlockingQueue
64 private void enqueue(java.util.concurrent.LinkedBlockingQueue.Node<E> node) { in enqueue()
119 java.util.concurrent.LinkedBlockingQueue.Node<E> p, in unlink()
120 java.util.concurrent.LinkedBlockingQueue.Node<E> trail) { in unlink()
187 transient java.util.concurrent.LinkedBlockingQueue.Node<E> head;
189 private transient java.util.concurrent.LinkedBlockingQueue.Node<E> last;
238 private java.util.concurrent.LinkedBlockingQueue.Node<E> current;
[all …]
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DLinkedBlockingQueueTest.java21 import java.util.concurrent.LinkedBlockingQueue;
33 LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>(); in testForEach()
/libcore/ojluni/src/test/java/util/PriorityQueue/
DRemoveContains.java41 import java.util.concurrent.LinkedBlockingQueue;
82 test(new LinkedBlockingQueue<String>(10)); in main()
DNoNulls.java50 import java.util.concurrent.LinkedBlockingQueue;
89 new LinkedBlockingQueue<String>(nullCollection); in test()
136 new LinkedBlockingQueue<String>().add(null); in test()
/libcore/ojluni/src/test/java/util/Collection/
DBiggernYours.java50 import java.util.concurrent.LinkedBlockingQueue;
302 new LinkedBlockingQueue(),
303 new LinkedBlockingQueue() {
DIteratorAtEnd.java58 import java.util.concurrent.LinkedBlockingQueue;
115 testCollection(new LinkedBlockingQueue()); in testLinkedBlockingQueue()
DCollectionDefaults.java79 java.util.concurrent.LinkedBlockingQueue<Integer>::new,
DMOAT.java114 testCollection(new LinkedBlockingQueue<Integer>(20)); in realMain()
791 if ((q instanceof LinkedBlockingQueue) || in testQueue()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutors.java99 new LinkedBlockingQueue<Runnable>()); in newFixedThreadPool()
162 new LinkedBlockingQueue<Runnable>(), in newFixedThreadPool()
183 new LinkedBlockingQueue<Runnable>())); in newSingleThreadExecutor()
202 new LinkedBlockingQueue<Runnable>(), in newSingleThreadExecutor()
DExecutorCompletionService.java151 this.completionQueue = new LinkedBlockingQueue<Future<V>>(); in ExecutorCompletionService()
DLinkedBlockingQueue.java81 public class LinkedBlockingQueue<E> extends AbstractQueue<E> class
244 public LinkedBlockingQueue() { in LinkedBlockingQueue() method in LinkedBlockingQueue
255 public LinkedBlockingQueue(int capacity) { in LinkedBlockingQueue() method in LinkedBlockingQueue
271 public LinkedBlockingQueue(Collection<? extends E> c) { in LinkedBlockingQueue() method in LinkedBlockingQueue
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DCollectionAndMapModifyStreamTest.java36 import java.util.concurrent.LinkedBlockingQueue;
84 collections.add(new LinkedBlockingQueue<>(content)); in createCollections()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DAsynchronousFileChannelTest.java46 import java.util.concurrent.LinkedBlockingQueue;
665 final LinkedBlockingQueue<Thread> observedThreads = new LinkedBlockingQueue<>(); in testCustomExecutor()
/libcore/
Dopenjdk_java_files.bp1002 "ojluni/src/main/java/java/util/concurrent/LinkedBlockingQueue.java",
DEXPECTED_UPSTREAM1045 …va/util/concurrent/LinkedBlockingQueue.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…
/libcore/api/
Dcurrent.txt15618 …public class LinkedBlockingQueue<E> extends java.util.AbstractQueue<E> implements java.util.concur…
15619 ctor public LinkedBlockingQueue();
15620 ctor public LinkedBlockingQueue(int);
15621 ctor public LinkedBlockingQueue(java.util.Collection<? extends E>);