| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | CyclicBarrierTest.java | 111 awaitTermination(t); in testTwoParties()
136 awaitTermination(t1); in testAwait1_Interrupted_BrokenBarrier()
137 awaitTermination(t2); in testAwait1_Interrupted_BrokenBarrier()
162 awaitTermination(t1); in testAwait2_Interrupted_BrokenBarrier()
163 awaitTermination(t2); in testAwait2_Interrupted_BrokenBarrier()
181 awaitTermination(t); in testAwait3_TimeoutException()
208 awaitTermination(t1); in testAwait4_Timeout_BrokenBarrier()
209 awaitTermination(t2); in testAwait4_Timeout_BrokenBarrier()
236 awaitTermination(t1); in testAwait5_Timeout_BrokenBarrier()
237 awaitTermination(t2); in testAwait5_Timeout_BrokenBarrier()
[all …]
|
| D | ExchangerTest.java | 36 awaitTermination(t1); in testExchange()
37 awaitTermination(t2); in testExchange()
56 awaitTermination(t1); in testTimedExchange()
57 awaitTermination(t2); in testTimedExchange()
74 awaitTermination(t); in testExchange_InterruptedException()
91 awaitTermination(t); in testTimedExchange_InterruptedException()
109 awaitTermination(t); in testExchange_TimeoutException()
140 awaitTermination(t1); in testReplacementAfterExchange()
142 awaitTermination(t2); in testReplacementAfterExchange()
143 awaitTermination(t3); in testReplacementAfterExchange()
|
| D | AbstractQueuedLongSynchronizerTest.java | 291 awaitTermination(t1); in testHasQueuedThreads()
294 awaitTermination(t2); in testHasQueuedThreads()
328 awaitTermination(t1); in testIsQueued()
332 awaitTermination(t2); in testIsQueued()
351 awaitTermination(t1); in testGetFirstQueuedThread()
354 awaitTermination(t2); in testGetFirstQueuedThread()
373 awaitTermination(t1); in testHasContended()
376 awaitTermination(t2); in testHasContended()
401 awaitTermination(t1); in testGetQueuedThreads()
404 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | AbstractQueuedSynchronizerTest.java | 294 awaitTermination(t1); in testHasQueuedThreads()
297 awaitTermination(t2); in testHasQueuedThreads()
331 awaitTermination(t1); in testIsQueued()
335 awaitTermination(t2); in testIsQueued()
354 awaitTermination(t1); in testGetFirstQueuedThread()
357 awaitTermination(t2); in testGetFirstQueuedThread()
376 awaitTermination(t1); in testHasContended()
379 awaitTermination(t2); in testHasContended()
404 awaitTermination(t1); in testGetQueuedThreads()
407 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | ReentrantReadWriteLockTest.java | 307 awaitTermination(t); in testWriteLockInterruptibly_Interruptible()
327 awaitTermination(t); in testWriteTryLock_Interruptible()
347 awaitTermination(t); in testReadLockInterruptibly_Interruptible()
367 awaitTermination(t); in testReadTryLock_Interruptible()
401 awaitTermination(t); in testWriteTryLockWhenLocked()
419 awaitTermination(t); in testReadTryLockWhenLocked()
441 awaitTermination(t); in testMultipleReadLocks()
466 awaitTermination(t); in testWriteAfterReadLock()
486 awaitTermination(t1); in testWriteAfterMultipleReadLocks()
501 awaitTermination(t2); in testWriteAfterMultipleReadLocks()
[all …]
|
| D | LockSupportTest.java | 108 awaitTermination(t); in testParkBeforeUnpark()
146 awaitTermination(t); in testParkAfterUnpark()
184 awaitTermination(t); in testParkBeforeInterrupt()
224 awaitTermination(t); in testParkAfterInterrupt()
254 awaitTermination(t); in testParkTimesOut()
299 awaitTermination(t); in testGetBlocker()
336 awaitTermination(t); in testPark0()
360 awaitTermination(t); in testParkNeg()
|
| D | CountDownLatchTest.java | 72 awaitTermination(t); in testAwait()
97 awaitTermination(t); in testTimedAwait()
128 awaitTermination(t); in testAwait_Interruptible()
159 awaitTermination(t); in testTimedAwait_Interruptible()
174 awaitTermination(t); in testAwaitTimeout()
|
| D | ReentrantLockTest.java | 240 awaitTermination(t1); in testHasQueuedThreads()
243 awaitTermination(t2); in testHasQueuedThreads()
265 awaitTermination(t1); in testGetQueueLength()
268 awaitTermination(t2); in testGetQueueLength()
306 awaitTermination(t1); in testHasQueuedThread()
310 awaitTermination(t2); in testHasQueuedThread()
337 awaitTermination(t1); in testGetQueuedThreads()
342 awaitTermination(t2); in testGetQueuedThreads()
361 awaitTermination(t); in testTryLock_Interruptible()
378 awaitTermination(t); in testTryLockWhenLocked()
[all …]
|
| D | SemaphoreTest.java | 259 awaitTermination(t); in testInterruptible()
301 awaitTermination(t1); in testUninterruptible()
302 awaitTermination(t2); in testUninterruptible()
321 awaitTermination(t1); in testHasQueuedThreads()
324 awaitTermination(t2); in testHasQueuedThreads()
344 awaitTermination(t1); in testGetQueueLength()
347 awaitTermination(t2); in testGetQueueLength()
369 awaitTermination(t1); in testGetQueuedThreads()
373 awaitTermination(t2); in testGetQueuedThreads()
474 awaitTermination(t); in testSerialization()
[all …]
|
| D | FutureTaskTest.java | 414 awaitTermination(t); in testCancelInterrupt()
461 awaitTermination(t); in testCancelInterrupt_ThrowsSecurityException()
489 awaitTermination(t); in testCancelInterrupt_taskFails()
517 awaitTermination(t); in testCancelNoInterrupt()
558 awaitTermination(t1); in testGetRun()
559 awaitTermination(t2); in testGetRun()
598 awaitTermination(t1); in testGetSet()
599 awaitTermination(t2); in testGetSet()
647 awaitTermination(t1); in testTimedGet_Cancellation()
648 awaitTermination(t2); in testTimedGet_Cancellation()
[all …]
|
| D | PhaserTest.java | 308 awaitTermination(thread); in testArrive2()
424 awaitTermination(t);
492 awaitTermination(t1);
493 awaitTermination(t2);
521 awaitTermination(t);
550 awaitTermination(t);
580 awaitTermination(t);
606 awaitTermination(t);
629 awaitTermination(thread);
660 awaitTermination(thread);
[all …]
|
| D | BlockingQueueTest.java | 240 awaitTermination(t); in testTimedPollWithOffer()
262 awaitTermination(t);
281 awaitTermination(t);
303 awaitTermination(t);
322 awaitTermination(t);
|
| D | LinkedBlockingDequeTest.java | 576 awaitTermination(t); in testBlockingPut()
611 awaitTermination(t); in testPutWithTake()
638 awaitTermination(t); in testTimedOffer()
681 awaitTermination(t); in testBlockingTake()
749 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
808 awaitTermination(t); in testBlockingPutFirst()
843 awaitTermination(t); in testPutFirstWithTake()
870 awaitTermination(t); in testTimedOfferFirst()
902 awaitTermination(t); in testTakeFirstFromEmptyBlocksInterruptibly()
921 awaitTermination(t); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
|
| D | LinkedTransferQueueTest.java | 217 awaitTermination(t); in testBlockingTake()
287 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
311 awaitTermination(t, MEDIUM_DELAY_MS); in testTimedPollAfterInterrupt()
670 awaitTermination(t, MEDIUM_DELAY_MS); in testDrainToWithActivePut()
722 awaitTermination(t, MEDIUM_DELAY_MS); in testWaitingConsumer()
757 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer2()
813 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer4()
836 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer5()
880 awaitTermination(t, MEDIUM_DELAY_MS); in testTryTransfer3()
902 awaitTermination(t, MEDIUM_DELAY_MS); in testTryTransfer4()
[all …]
|
| D | SynchronousQueueTest.java | 122 awaitTermination(t); in testBlockingPut()
156 awaitTermination(t); in testPutWithTake()
183 awaitTermination(t); in testTimedOffer()
265 awaitTermination(t); in testTimedPollWithOffer()
559 awaitTermination(t);
585 awaitTermination(t1);
586 awaitTermination(t2);
|
| D | ForkJoinPoolTest.java | 230 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
231 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
232 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
233 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
234 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
235 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
238 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
243 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
247 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
|
| D | TimeUnitTest.java | 347 awaitTermination(t); in testTimedWait_IllegalMonitorException()
382 awaitTermination(t); in testTimedWait_Interruptible()
415 awaitTermination(t); in testTimedJoin_Interruptible()
417 awaitTermination(s); in testTimedJoin_Interruptible()
446 awaitTermination(t); in testTimedSleep_Interruptible()
|
| D | ThreadPoolExecutorTest.java | 409 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
410 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
411 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
412 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
413 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
414 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
417 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
422 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
426 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
454 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
[all …]
|
| D | ThreadLocalRandomTest.java | 277 awaitTermination(first);
283 awaitTermination(t);
|
| D | LinkedBlockingQueueTest.java | 266 awaitTermination(t); in testBlockingPut()
301 awaitTermination(t); in testPutWithTake()
328 awaitTermination(t); in testTimedOffer()
371 awaitTermination(t); in testBlockingTake()
439 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
|
| D | PriorityBlockingQueueTest.java | 266 awaitTermination(t); in testPutWithTake()
284 awaitTermination(t); in testTimedOffer()
327 awaitTermination(t); in testBlockingTake()
395 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
|
| D | JSR166TestCase.java | 389 exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)); in joinPool()
647 void awaitTermination(Thread t, long timeoutMillis) { in awaitTermination() method in JSR166TestCase
665 void awaitTermination(Thread t) { in awaitTermination() method in JSR166TestCase
666 awaitTermination(t, LONG_DELAY_MS); in awaitTermination()
|
| D | ArrayBlockingQueueTest.java | 276 awaitTermination(t); in testBlockingPut()
311 awaitTermination(t); in testPutWithTake()
338 awaitTermination(t); in testTimedOffer()
381 awaitTermination(t); in testBlockingTake()
450 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ExecutorService.java | 170 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method
|
| D | Executors.java | 588 public boolean awaitTermination(long timeout, TimeUnit unit)
590 return e.awaitTermination(timeout, unit);
|