| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ArrayBlockingQueueTest.java | 19 import java.util.concurrent.ArrayBlockingQueue;
60 private ArrayBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
61 ArrayBlockingQueue<Integer> q = new ArrayBlockingQueue<Integer>(n); in populatedQueue()
75 assertEquals(SIZE, new ArrayBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
83 new ArrayBlockingQueue(0); in testConstructor2()
93 new ArrayBlockingQueue(1, true, null); in testConstructor3()
104 new ArrayBlockingQueue(SIZE, false, elements); in testConstructor4()
118 new ArrayBlockingQueue(SIZE, false, elements); in testConstructor5()
132 new ArrayBlockingQueue(SIZE - 1, false, elements); in testConstructor6()
145 ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, true, elements); in testConstructor7()
[all …]
|
| D | ThreadPoolExecutorTest.java | 17 import java.util.concurrent.ArrayBlockingQueue;
94 new ArrayBlockingQueue<Runnable>(10)); in testExecute()
113 new ArrayBlockingQueue<Runnable>(10)); in testGetActiveCount()
135 new ArrayBlockingQueue<Runnable>(10)); in testPrestartCoreThread()
161 new ArrayBlockingQueue<Runnable>(10)); in testPrestartAllCoreThreads()
184 new ArrayBlockingQueue<Runnable>(10)); in testGetCompletedTaskCount()
217 new ArrayBlockingQueue<Runnable>(10)); in testGetCorePoolSize()
230 new ArrayBlockingQueue<Runnable>(10)); in testGetKeepAliveTime()
244 new ArrayBlockingQueue<Runnable>(10), in testGetThreadFactory()
259 new ArrayBlockingQueue<Runnable>(10)); in testSetThreadFactory()
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 16 import java.util.concurrent.ArrayBlockingQueue;
241 new ArrayBlockingQueue<Runnable>(10)); in testExecute()
260 new ArrayBlockingQueue<Runnable>(10)); in testGetActiveCount()
282 new ArrayBlockingQueue<Runnable>(10)); in testPrestartCoreThread()
308 new ArrayBlockingQueue<Runnable>(10)); in testPrestartAllCoreThreads()
331 new ArrayBlockingQueue<Runnable>(10)); in testGetCompletedTaskCount()
364 new ArrayBlockingQueue<Runnable>(10)); in testGetCorePoolSize()
377 new ArrayBlockingQueue<Runnable>(10)); in testGetKeepAliveTime()
391 new ArrayBlockingQueue<Runnable>(10), in testGetThreadFactory()
406 new ArrayBlockingQueue<Runnable>(10)); in testSetThreadFactory()
[all …]
|
| D | ArrayBlockingQueueFairTest.java | 11 import java.util.concurrent.ArrayBlockingQueue;
22 return new ArrayBlockingQueue(SIZE, true); in emptyCollection()
|
| D | ArrayBlockingQueueNonFairTest.java | 11 import java.util.concurrent.ArrayBlockingQueue;
17 return new ArrayBlockingQueue(SIZE, false); in emptyCollection()
|
| D | ExecutorCompletionServiceTest.java | 13 import java.util.concurrent.ArrayBlockingQueue;
170 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForCallable()
201 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForRunnable()
|
| D | AbstractExecutorServiceTest.java | 19 import java.util.concurrent.ArrayBlockingQueue;
207 new ArrayBlockingQueue<Runnable>(10)); in testInterruptedSubmit()
230 new ArrayBlockingQueue<Runnable>(10)); in testSubmitEE()
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | ThreadPoolExecutorTest.java | 21 import java.util.concurrent.ArrayBlockingQueue;
31 1000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10)); in testCorePoolSizeGreaterThanMax()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ArrayBlockingQueue.java | 85 public class ArrayBlockingQueue<E> extends AbstractQueue<E> class
224 public ArrayBlockingQueue(int capacity) { in ArrayBlockingQueue() method in ArrayBlockingQueue
238 public ArrayBlockingQueue(int capacity, boolean fair) { in ArrayBlockingQueue() method in ArrayBlockingQueue
263 public ArrayBlockingQueue(int capacity, boolean fair, in ArrayBlockingQueue() method in ArrayBlockingQueue
1013 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in Itr()
1022 final int takeIndex = ArrayBlockingQueue.this.takeIndex; in Itr()
1080 final int takeIndex = ArrayBlockingQueue.this.takeIndex; in incorporateDequeues()
1145 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in noNext()
1171 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in next()
1196 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in remove()
[all …]
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | EPollPort.java | 30 import java.util.concurrent.ArrayBlockingQueue;
79 private final ArrayBlockingQueue<Event> queue;
108 this.queue = new ArrayBlockingQueue<Event>(MAX_EPOLL_EVENTS); in EPollPort()
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | CollectionAndMapModifyStreamTest.java | 27 import java.util.concurrent.ArrayBlockingQueue;
79 ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(content.size()); in createCollections()
|
| /libcore/ |
| D | openjdk_java_files.bp | 923 "ojluni/src/main/java/java/util/concurrent/ArrayBlockingQueue.java",
|