Searched refs:ArrayBlockingQueue (Results 1 - 12 of 12) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
H A DArrayBlockingQueueFairTest.java11 import java.util.concurrent.ArrayBlockingQueue;
22 return new ArrayBlockingQueue(SIZE, true);
H A DArrayBlockingQueueNonFairTest.java11 import java.util.concurrent.ArrayBlockingQueue;
17 return new ArrayBlockingQueue(SIZE, false);
H A DArrayBlockingQueueTest.java19 import java.util.concurrent.ArrayBlockingQueue;
34 // return new ArrayBlockingQueue(SIZE, true);
40 // return new ArrayBlockingQueue(SIZE, false);
60 private ArrayBlockingQueue<Integer> populatedQueue(int n) {
61 ArrayBlockingQueue<Integer> q = new ArrayBlockingQueue<Integer>(n);
75 assertEquals(SIZE, new ArrayBlockingQueue(SIZE).remainingCapacity());
83 new ArrayBlockingQueue(0);
93 new ArrayBlockingQueue(1, true, null);
104 new ArrayBlockingQueue(SIZ
[all...]
H A DThreadPoolExecutorTest.java17 import java.util.concurrent.ArrayBlockingQueue;
94 new ArrayBlockingQueue<Runnable>(10));
113 new ArrayBlockingQueue<Runnable>(10));
135 new ArrayBlockingQueue<Runnable>(10));
161 new ArrayBlockingQueue<Runnable>(10));
184 new ArrayBlockingQueue<Runnable>(10));
217 new ArrayBlockingQueue<Runnable>(10));
230 new ArrayBlockingQueue<Runnable>(10));
244 new ArrayBlockingQueue<Runnable>(10),
259 new ArrayBlockingQueue<Runnabl
[all...]
H A DThreadPoolExecutorSubclassTest.java16 import java.util.concurrent.ArrayBlockingQueue;
241 new ArrayBlockingQueue<Runnable>(10));
260 new ArrayBlockingQueue<Runnable>(10));
282 new ArrayBlockingQueue<Runnable>(10));
308 new ArrayBlockingQueue<Runnable>(10));
331 new ArrayBlockingQueue<Runnable>(10));
364 new ArrayBlockingQueue<Runnable>(10));
377 new ArrayBlockingQueue<Runnable>(10));
391 new ArrayBlockingQueue<Runnable>(10),
406 new ArrayBlockingQueue<Runnabl
[all...]
H A DExecutorCompletionServiceTest.java13 import java.util.concurrent.ArrayBlockingQueue;
170 new ArrayBlockingQueue<Runnable>(1)) {
201 new ArrayBlockingQueue<Runnable>(1)) {
H A DAbstractExecutorServiceTest.java19 import java.util.concurrent.ArrayBlockingQueue;
207 new ArrayBlockingQueue<Runnable>(10));
230 new ArrayBlockingQueue<Runnable>(10));
/libcore/luni/src/test/java/libcore/java/util/concurrent/
H A DThreadPoolExecutorTest.java21 import java.util.concurrent.ArrayBlockingQueue;
31 1000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10));
/libcore/ojluni/src/main/java/sun/nio/ch/
H A DEPollPort.java30 import java.util.concurrent.ArrayBlockingQueue;
79 private final ArrayBlockingQueue<Event> queue;
108 this.queue = new ArrayBlockingQueue<Event>(MAX_EPOLL_EVENTS);
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DArrayBlockingQueue.java85 public class ArrayBlockingQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,BlockingQueue,java.io.Serializable
218 * Creates an {@code ArrayBlockingQueue} with the given (fixed)
224 public ArrayBlockingQueue(int capacity) { method in class:ArrayBlockingQueue
229 * Creates an {@code ArrayBlockingQueue} with the given (fixed)
238 public ArrayBlockingQueue(int capacity, boolean fair) { method in class:ArrayBlockingQueue
248 * Creates an {@code ArrayBlockingQueue} with the given (fixed)
263 public ArrayBlockingQueue(int capacity, boolean fair, method in class:ArrayBlockingQueue
959 * Iterator for ArrayBlockingQueue.
1013 final ReentrantLock lock = ArrayBlockingQueue.this.lock;
1022 final int takeIndex = ArrayBlockingQueue
[all...]
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DCollectionAndMapModifyStreamTest.java27 import java.util.concurrent.ArrayBlockingQueue;
79 ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(content.size());
/libcore/
H A Dopenjdk_java_files.mk920 ojluni/src/main/java/java/util/concurrent/ArrayBlockingQueue.java \

Completed in 2992 milliseconds