| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | LinkedBlockingQueueTest.java | 23 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 …]
|
| D | LinkedBlockingQueueUnboundedTest.java | 12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue(); in emptyCollection()
|
| D | LinkedBlockingQueueBoundedTest.java | 12 import java.util.concurrent.LinkedBlockingQueue;
17 return new LinkedBlockingQueue(SIZE); in emptyCollection()
|
| D | ThreadPoolExecutorSubclassTest.java | 26 import java.util.concurrent.LinkedBlockingQueue;
1925 new LinkedBlockingQueue<Runnable>(),
2011 new LinkedBlockingQueue<Runnable>());
|
| D | ThreadPoolExecutorTest.java | 27 import java.util.concurrent.LinkedBlockingQueue;
1932 new LinkedBlockingQueue<Runnable>(),
2047 new LinkedBlockingQueue<Runnable>());
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | LinkedBlockingQueueTest.java | 49 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 …]
|
| D | LinkedBlockingQueue8Test.java | 36 import java.util.concurrent.LinkedBlockingQueue;
56 () -> new LinkedBlockingQueue().spliterator().getComparator()); in testSpliterator_getComparator()
63 LinkedBlockingQueue q = new LinkedBlockingQueue(); in testSpliterator_characteristics()
|
| D | ThreadPoolExecutorSubclassTest.java | 51 import java.util.concurrent.LinkedBlockingQueue;
1947 new LinkedBlockingQueue<Runnable>(),
2033 new LinkedBlockingQueue<Runnable>());
|
| D | ThreadPoolExecutorTest.java | 53 import java.util.concurrent.LinkedBlockingQueue;
1949 new LinkedBlockingQueue<Runnable>(),
2064 new LinkedBlockingQueue<Runnable>());
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | LinkedBlockingQueue.java | 41 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/ojluni/src/main/java/java/util/concurrent/ |
| D | LinkedBlockingQueue.java | 80 public class LinkedBlockingQueue<E> extends AbstractQueue<E> class
249 public LinkedBlockingQueue() { in LinkedBlockingQueue() method in LinkedBlockingQueue
260 public LinkedBlockingQueue(int capacity) { in LinkedBlockingQueue() method in LinkedBlockingQueue
276 public LinkedBlockingQueue(Collection<? extends E> c) { in LinkedBlockingQueue() method in LinkedBlockingQueue
831 final LinkedBlockingQueue<E> queue;
836 LBQSpliterator(LinkedBlockingQueue<E> queue) { in LBQSpliterator()
845 final LinkedBlockingQueue<E> q = this.queue; in trySplit()
884 final LinkedBlockingQueue<E> q = this.queue; in forEachRemaining()
911 final LinkedBlockingQueue<E> q = this.queue; in tryAdvance()
|
| D | Executors.java | 98 new LinkedBlockingQueue<Runnable>()); in newFixedThreadPool()
161 new LinkedBlockingQueue<Runnable>(), in newFixedThreadPool()
182 new LinkedBlockingQueue<Runnable>())); in newSingleThreadExecutor()
203 new LinkedBlockingQueue<Runnable>(), in newSingleThreadExecutor()
|
| D | ExecutorCompletionService.java | 154 this.completionQueue = new LinkedBlockingQueue<Future<V>>(); in ExecutorCompletionService()
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | CollectionAndMapModifyStreamTest.java | 36 import java.util.concurrent.LinkedBlockingQueue;
84 collections.add(new LinkedBlockingQueue<>(content)); in createCollections()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | AsynchronousFileChannelTest.java | 44 import java.util.concurrent.LinkedBlockingQueue;
663 final LinkedBlockingQueue<Thread> observedThreads = new LinkedBlockingQueue<>(); in testCustomExecutor()
|
| /libcore/ |
| D | openjdk_java_files.bp | 968 "ojluni/src/main/java/java/util/concurrent/LinkedBlockingQueue.java",
|
| /libcore/api/ |
| D | current.txt | 14838 …public class LinkedBlockingQueue<E> extends java.util.AbstractQueue<E> implements java.util.concur…
14839 ctor public LinkedBlockingQueue();
14840 ctor public LinkedBlockingQueue(int);
14841 ctor public LinkedBlockingQueue(java.util.Collection<? extends E>);
|