Home
last modified time | relevance | path

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

12

/libcore/jsr166-tests/src/test/java/jsr166/
DArrayBlockingQueueTest.java19 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 …]
DThreadPoolExecutorTest.java17 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 …]
DThreadPoolExecutorSubclassTest.java16 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 …]
DArrayBlockingQueueFairTest.java11 import java.util.concurrent.ArrayBlockingQueue;
22 return new ArrayBlockingQueue(SIZE, true); in emptyCollection()
DArrayBlockingQueueNonFairTest.java11 import java.util.concurrent.ArrayBlockingQueue;
17 return new ArrayBlockingQueue(SIZE, false); in emptyCollection()
DExecutorCompletionServiceTest.java13 import java.util.concurrent.ArrayBlockingQueue;
170 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForCallable()
201 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForRunnable()
DAbstractExecutorServiceTest.java19 import java.util.concurrent.ArrayBlockingQueue;
207 new ArrayBlockingQueue<Runnable>(10)); in testInterruptedSubmit()
230 new ArrayBlockingQueue<Runnable>(10)); in testSubmitEE()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DArrayBlockingQueueTest.java46 import java.util.concurrent.ArrayBlockingQueue;
63 public Class<?> klazz() { return ArrayBlockingQueue.class; } in suite()
96 static ArrayBlockingQueue<Integer> populatedQueue(int n) { in populatedQueue()
104 static ArrayBlockingQueue<Integer> populatedQueue( in populatedQueue()
108 ArrayBlockingQueue<Integer> q = new ArrayBlockingQueue<>(capacity); in populatedQueue()
130 assertEquals(SIZE, new ArrayBlockingQueue(SIZE).remainingCapacity()); in testConstructor1()
139 new ArrayBlockingQueue(i); in testConstructor_nonPositiveCapacity()
144 new ArrayBlockingQueue(i, fair); in testConstructor_nonPositiveCapacity()
156 new ArrayBlockingQueue(1, true, null); in testConstructor_nullCollection()
167 new ArrayBlockingQueue(SIZE, false, elements); in testConstructor4()
[all …]
DThreadPoolExecutorTest.java43 import java.util.concurrent.ArrayBlockingQueue;
116 new ArrayBlockingQueue<Runnable>(10)); in testExecute()
135 new ArrayBlockingQueue<Runnable>(10)); in testGetActiveCount()
157 new ArrayBlockingQueue<Runnable>(10)); in testPrestartCoreThread()
183 new ArrayBlockingQueue<Runnable>(10)); in testPrestartAllCoreThreads()
206 new ArrayBlockingQueue<Runnable>(10)); in testGetCompletedTaskCount()
239 new ArrayBlockingQueue<Runnable>(10)); in testGetCorePoolSize()
252 new ArrayBlockingQueue<Runnable>(10)); in testGetKeepAliveTime()
266 new ArrayBlockingQueue<Runnable>(10), in testGetThreadFactory()
281 new ArrayBlockingQueue<Runnable>(10)); in testSetThreadFactory()
[all …]
DThreadPoolExecutorSubclassTest.java42 import java.util.concurrent.ArrayBlockingQueue;
263 new ArrayBlockingQueue<Runnable>(10)); in testExecute()
282 new ArrayBlockingQueue<Runnable>(10)); in testGetActiveCount()
304 new ArrayBlockingQueue<Runnable>(10)); in testPrestartCoreThread()
330 new ArrayBlockingQueue<Runnable>(10)); in testPrestartAllCoreThreads()
353 new ArrayBlockingQueue<Runnable>(10)); in testGetCompletedTaskCount()
386 new ArrayBlockingQueue<Runnable>(10)); in testGetCorePoolSize()
399 new ArrayBlockingQueue<Runnable>(10)); in testGetKeepAliveTime()
413 new ArrayBlockingQueue<Runnable>(10), in testGetThreadFactory()
428 new ArrayBlockingQueue<Runnable>(10)); in testSetThreadFactory()
[all …]
DExecutorCompletionServiceTest.java39 import java.util.concurrent.ArrayBlockingQueue;
231 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForCallable()
261 new ArrayBlockingQueue<Runnable>(1)) { in testNewTaskForRunnable()
DAbstractExecutorServiceTest.java45 import java.util.concurrent.ArrayBlockingQueue;
230 new ArrayBlockingQueue<Runnable>(10)); in testInterruptedSubmit()
253 new ArrayBlockingQueue<Runnable>(10)); in testSubmitEE()
DCollection8Test.java412 && !(c instanceof java.util.concurrent.ArrayBlockingQueue)) {
484 && !(c instanceof java.util.concurrent.ArrayBlockingQueue))
613 if (c instanceof java.util.concurrent.ArrayBlockingQueue) {
/libcore/ojluni/src/test/java/util/Collections/
DCheckedQueue.java35 import java.util.concurrent.ArrayBlockingQueue;
52 … Queue<String> abq = Collections.checkedQueue(new ArrayBlockingQueue<>(arrayLength), String.class); in testAdd()
73 ArrayBlockingQueue<String> abq = new ArrayBlockingQueue(arrayLength + 1); in testAddFail1()
90 ArrayBlockingQueue<String> abq = new ArrayBlockingQueue(1); in testAddFail2()
102 ArrayBlockingQueue<String> abq = new ArrayBlockingQueue(1); in testArgs()
132 ArrayBlockingQueue<String> abq = new ArrayBlockingQueue(1); in testOffer()
DRacingCollections.java50 import java.util.concurrent.ArrayBlockingQueue;
277 list.add(new ArrayBlockingQueue<Integer>(10)); in newConcurrentQueues()
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DArrayBlockingQueueTest.java21 import java.util.concurrent.ArrayBlockingQueue;
33 ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(capacity); in testForEach()
DThreadPoolExecutorTest.java21 import java.util.concurrent.ArrayBlockingQueue;
31 1000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10)); in testCorePoolSizeGreaterThanMax()
/libcore/ojluni/src/test/java/util/PriorityQueue/
DNoNulls.java48 import java.util.concurrent.ArrayBlockingQueue;
83 new ArrayBlockingQueue<String>(10, false, nullCollection); in test()
86 new ArrayBlockingQueue<String>(10, true, nullCollection); in test()
130 new ArrayBlockingQueue<String>(10, false).add(null); in test()
133 new ArrayBlockingQueue<String>(10, true).add(null); in test()
DRemoveContains.java39 import java.util.concurrent.ArrayBlockingQueue;
81 test(new ArrayBlockingQueue<String>(10)); in main()
/libcore/ojluni/src/main/java/java/util/concurrent/
DArrayBlockingQueue.java86 public class ArrayBlockingQueue<E> extends AbstractQueue<E> class
256 public ArrayBlockingQueue(int capacity) { in ArrayBlockingQueue() method in ArrayBlockingQueue
270 public ArrayBlockingQueue(int capacity, boolean fair) { in ArrayBlockingQueue() method in ArrayBlockingQueue
295 public ArrayBlockingQueue(int capacity, boolean fair, in ArrayBlockingQueue() method in ArrayBlockingQueue
1060 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in Itr()
1069 final int takeIndex = ArrayBlockingQueue.this.takeIndex; in Itr()
1127 final int takeIndex = ArrayBlockingQueue.this.takeIndex; in incorporateDequeues()
1191 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in noNext()
1216 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in next()
1242 final ReentrantLock lock = ArrayBlockingQueue.this.lock; in forEachRemaining()
[all …]
/libcore/ojluni/src/main/java/sun/nio/ch/
DEPollPort.java30 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/
DCollectionAndMapModifyStreamTest.java27 import java.util.concurrent.ArrayBlockingQueue;
80 ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(content.size()); in createCollections()
/libcore/ojluni/src/test/java/util/Collection/
DBiggernYours.java41 import java.util.concurrent.ArrayBlockingQueue;
324 new ArrayBlockingQueue(5),
325 new ArrayBlockingQueue(5) {
DIteratorAtEnd.java50 import java.util.concurrent.ArrayBlockingQueue;
120 testCollection(new ArrayBlockingQueue(100)); in testArrayBlockingQueue()
DCollectionDefaults.java81 (coll) -> new java.util.concurrent.ArrayBlockingQueue<Integer>(

12