Searched refs:ArrayBlockingQueue (Results 1 - 11 of 11) sorted by relevance
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | ArrayBlockingQueueFairTest.java | 11 import java.util.concurrent.ArrayBlockingQueue; 22 return new ArrayBlockingQueue(SIZE, true);
|
H A D | ArrayBlockingQueueNonFairTest.java | 11 import java.util.concurrent.ArrayBlockingQueue; 17 return new ArrayBlockingQueue(SIZE, false);
|
H A D | ArrayBlockingQueueTest.java | 19 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 D | ThreadPoolExecutorTest.java | 17 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 D | ThreadPoolExecutorSubclassTest.java | 16 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 D | ExecutorCompletionServiceTest.java | 13 import java.util.concurrent.ArrayBlockingQueue; 170 new ArrayBlockingQueue<Runnable>(1)) { 201 new ArrayBlockingQueue<Runnable>(1)) {
|
H A D | AbstractExecutorServiceTest.java | 19 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 D | ThreadPoolExecutorTest.java | 21 import java.util.concurrent.ArrayBlockingQueue; 31 1000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10));
|
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | ArrayBlockingQueue.java | 56 public class ArrayBlockingQueue<E> extends AbstractQueue<E> class in inherits:AbstractQueue,BlockingQueue,java.io.Serializable 189 * Creates an {@code ArrayBlockingQueue} with the given (fixed) 195 public ArrayBlockingQueue(int capacity) { method in class:ArrayBlockingQueue 200 * Creates an {@code ArrayBlockingQueue} with the given (fixed) 209 public ArrayBlockingQueue(int capacity, boolean fair) { method in class:ArrayBlockingQueue 219 * Creates an {@code ArrayBlockingQueue} with the given (fixed) 234 public ArrayBlockingQueue(int capacity, boolean fair, method in class:ArrayBlockingQueue 930 * Iterator for ArrayBlockingQueue. 984 final ReentrantLock lock = ArrayBlockingQueue.this.lock; 993 final int takeIndex = ArrayBlockingQueue [all...] |
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A D | CollectionAndMapModifyStreamTest.java | 27 import java.util.concurrent.ArrayBlockingQueue; 79 ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(content.size());
|
/libcore/ |
H A D | non_openjdk_java_files.mk | 86 luni/src/main/java/java/util/concurrent/ArrayBlockingQueue.java \
|
Completed in 282 milliseconds