| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | CyclicBarrierTest.java | 122 awaitTermination(t); in testTwoParties()
147 awaitTermination(t1); in testAwait1_Interrupted_BrokenBarrier()
148 awaitTermination(t2); in testAwait1_Interrupted_BrokenBarrier()
173 awaitTermination(t1); in testAwait2_Interrupted_BrokenBarrier()
174 awaitTermination(t2); in testAwait2_Interrupted_BrokenBarrier()
192 awaitTermination(t); in testAwait3_TimeoutException()
219 awaitTermination(t1); in testAwait4_Timeout_BrokenBarrier()
220 awaitTermination(t2); in testAwait4_Timeout_BrokenBarrier()
247 awaitTermination(t1); in testAwait5_Timeout_BrokenBarrier()
248 awaitTermination(t2); in testAwait5_Timeout_BrokenBarrier()
[all …]
|
| D | ExchangerTest.java | 48 awaitTermination(t1); in testExchange()
49 awaitTermination(t2); in testExchange()
68 awaitTermination(t1); in testTimedExchange()
69 awaitTermination(t2); in testTimedExchange()
86 awaitTermination(t); in testExchange_InterruptedException()
103 awaitTermination(t); in testTimedExchange_InterruptedException()
121 awaitTermination(t); in testExchange_TimeoutException()
152 awaitTermination(t1); in testReplacementAfterExchange()
154 awaitTermination(t2); in testReplacementAfterExchange()
155 awaitTermination(t3); in testReplacementAfterExchange()
|
| D | ReentrantReadWriteLockTest.java | 326 awaitTermination(t); in testWriteLockInterruptibly_Interruptible()
346 awaitTermination(t); in testWriteTryLock_Interruptible()
366 awaitTermination(t); in testReadLockInterruptibly_Interruptible()
386 awaitTermination(t); in testReadTryLock_Interruptible()
420 awaitTermination(t); in testWriteTryLockWhenLocked()
438 awaitTermination(t); in testReadTryLockWhenLocked()
460 awaitTermination(t); in testMultipleReadLocks()
485 awaitTermination(t); in testWriteAfterReadLock()
505 awaitTermination(t1); in testWriteAfterMultipleReadLocks()
520 awaitTermination(t2); in testWriteAfterMultipleReadLocks()
[all …]
|
| D | AbstractQueuedSynchronizerTest.java | 320 awaitTermination(t1); in testHasQueuedThreads()
323 awaitTermination(t2); in testHasQueuedThreads()
357 awaitTermination(t1); in testIsQueued()
361 awaitTermination(t2); in testIsQueued()
380 awaitTermination(t1); in testGetFirstQueuedThread()
383 awaitTermination(t2); in testGetFirstQueuedThread()
402 awaitTermination(t1); in testHasContended()
405 awaitTermination(t2); in testHasContended()
430 awaitTermination(t1); in testGetQueuedThreads()
433 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | AbstractQueuedLongSynchronizerTest.java | 317 awaitTermination(t1); in testHasQueuedThreads()
320 awaitTermination(t2); in testHasQueuedThreads()
354 awaitTermination(t1); in testIsQueued()
358 awaitTermination(t2); in testIsQueued()
377 awaitTermination(t1); in testGetFirstQueuedThread()
380 awaitTermination(t2); in testGetFirstQueuedThread()
399 awaitTermination(t1); in testHasContended()
402 awaitTermination(t2); in testHasContended()
427 awaitTermination(t1); in testGetQueuedThreads()
430 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | LockSupportTest.java | 126 awaitTermination(t); in testParkBeforeUnpark()
164 awaitTermination(t); in testParkAfterUnpark()
202 awaitTermination(t); in testParkBeforeInterrupt()
242 awaitTermination(t); in testParkAfterInterrupt()
272 awaitTermination(t); in testParkTimesOut()
317 awaitTermination(t); in testGetBlocker()
354 awaitTermination(t); in testPark0()
378 awaitTermination(t); in testParkNeg()
|
| D | ReentrantLockTest.java | 258 awaitTermination(t1); in testHasQueuedThreads()
261 awaitTermination(t2); in testHasQueuedThreads()
283 awaitTermination(t1); in testGetQueueLength()
286 awaitTermination(t2); in testGetQueueLength()
324 awaitTermination(t1); in testHasQueuedThread()
328 awaitTermination(t2); in testHasQueuedThread()
355 awaitTermination(t1); in testGetQueuedThreads()
360 awaitTermination(t2); in testGetQueuedThreads()
379 awaitTermination(t); in testTryLock_Interruptible()
396 awaitTermination(t); in testTryLockWhenLocked()
[all …]
|
| D | CountDownLatchTest.java | 83 awaitTermination(t); in testAwait()
108 awaitTermination(t); in testTimedAwait()
139 awaitTermination(t); in testAwait_Interruptible()
170 awaitTermination(t); in testTimedAwait_Interruptible()
185 awaitTermination(t); in testAwaitTimeout()
|
| D | StampedLockTest.java | 297 awaitTermination(t); in testWriteLockInterruptibly_Interruptible()
317 awaitTermination(t); in testWriteTryLock_Interruptible()
338 awaitTermination(t); in testReadLockInterruptibly_Interruptible()
358 awaitTermination(t); in testReadTryLock_Interruptible()
387 awaitTermination(t); in testWriteTryLockWhenLocked()
403 awaitTermination(t); in testReadTryLockWhenLocked()
425 awaitTermination(t); in testMultipleReadLocks()
447 awaitTermination(t); in testWriteAfterReadLock()
463 awaitTermination(t1); in testWriteAfterMultipleReadLocks()
473 awaitTermination(t2); in testWriteAfterMultipleReadLocks()
[all …]
|
| D | SemaphoreTest.java | 272 awaitTermination(t); in testInterruptible()
314 awaitTermination(t1); in testUninterruptible()
315 awaitTermination(t2); in testUninterruptible()
334 awaitTermination(t1); in testHasQueuedThreads()
337 awaitTermination(t2); in testHasQueuedThreads()
357 awaitTermination(t1); in testGetQueueLength()
360 awaitTermination(t2); in testGetQueueLength()
382 awaitTermination(t1); in testGetQueuedThreads()
386 awaitTermination(t2); in testGetQueuedThreads()
492 awaitTermination(t); in testSerialization()
[all …]
|
| D | PhaserTest.java | 319 awaitTermination(thread); in testArrive2()
435 awaitTermination(t);
503 awaitTermination(t1);
504 awaitTermination(t2);
532 awaitTermination(t);
561 awaitTermination(t);
591 awaitTermination(t);
617 awaitTermination(t);
640 awaitTermination(thread);
671 awaitTermination(thread);
[all …]
|
| D | FutureTaskTest.java | 432 awaitTermination(t); in testCancelInterrupt()
479 awaitTermination(t); in testCancelInterrupt_ThrowsSecurityException()
507 awaitTermination(t); in testCancelInterrupt_taskFails()
535 awaitTermination(t); in testCancelNoInterrupt()
576 awaitTermination(t1); in testGetRun()
577 awaitTermination(t2); in testGetRun()
616 awaitTermination(t1); in testGetSet()
617 awaitTermination(t2); in testGetSet()
665 awaitTermination(t1); in testTimedGet_Cancellation()
666 awaitTermination(t2); in testTimedGet_Cancellation()
[all …]
|
| D | BlockingQueueTest.java | 254 awaitTermination(t); in testTimedPollWithOffer()
276 awaitTermination(t);
295 awaitTermination(t);
317 awaitTermination(t);
336 awaitTermination(t);
|
| D | LinkedTransferQueueTest.java | 244 awaitTermination(t); in testBlockingTake()
310 awaitTermination(t); in testInterruptedTimedPoll()
333 awaitTermination(t); in testTimedPollAfterInterrupt()
709 awaitTermination(t); in testDrainToWithActivePut()
764 awaitTermination(t); in testWaitingConsumer()
802 awaitTermination(t); in testTransfer2()
858 awaitTermination(t); in testTransfer4()
881 awaitTermination(t); in testTransfer5()
927 awaitTermination(t); in testTryTransfer3()
949 awaitTermination(t);
[all …]
|
| D | LinkedBlockingDequeTest.java | 603 awaitTermination(t); in testBlockingPut()
638 awaitTermination(t); in testPutWithTake()
665 awaitTermination(t); in testTimedOffer()
708 awaitTermination(t); in testBlockingTake()
774 awaitTermination(t); in testInterruptedTimedPoll()
833 awaitTermination(t); in testBlockingPutFirst()
868 awaitTermination(t); in testPutFirstWithTake()
895 awaitTermination(t); in testTimedOfferFirst()
927 awaitTermination(t); in testTakeFirstFromEmptyBlocksInterruptibly()
946 awaitTermination(t); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
|
| D | SynchronousQueueTest.java | 150 awaitTermination(t); in testBlockingPut()
184 awaitTermination(t); in testPutWithTake()
211 awaitTermination(t); in testTimedOffer()
294 awaitTermination(t); in testTimedPollWithOffer()
582 awaitTermination(t);
610 awaitTermination(t1);
611 awaitTermination(t2);
|
| D | TimeUnitTest.java | 330 awaitTermination(t); in testTimedWait_IllegalMonitorException()
365 awaitTermination(t); in testTimedWait_Interruptible()
398 awaitTermination(t); in testTimedJoin_Interruptible()
400 awaitTermination(s); in testTimedJoin_Interruptible()
429 awaitTermination(t); in testTimedSleep_Interruptible()
|
| D | ForkJoinPoolTest.java | 249 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
250 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
251 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
252 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
253 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
254 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
257 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
262 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
266 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
590 awaitTermination(t); in testInterruptedSubmit()
|
| D | ThreadPoolExecutorTest.java | 462 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
463 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
464 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
465 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
466 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
467 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
470 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
475 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
479 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
506 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
[all …]
|
| D | ThreadLocalRandomTest.java | 333 awaitTermination(first);
339 awaitTermination(t);
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | AsynchronousChannelGroupTest.java | 106 assertFalse(acg.awaitTermination(2, TimeUnit.SECONDS)); in test_shutdown()
150 assertTrue(acg.awaitTermination(TIMEOUT, TimeUnit.SECONDS)); in test_isTerminated()
163 assertFalse(acg.awaitTermination(TIMEOUT, TimeUnit.SECONDS)); in test_awaitTermination()
167 assertTrue(acg.awaitTermination(TIMEOUT, TimeUnit.SECONDS)); in test_awaitTermination()
|
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| D | AsynchronousChannelGroup.java | 341 public abstract boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method in AsynchronousChannelGroup
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorService.java | 200 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | AsynchronousChannelGroupImpl.java | 306 public final boolean awaitTermination(long timeout, TimeUnit unit)
309 return pool.executor().awaitTermination(timeout, unit);
|
| /libcore/luni/src/test/java/libcore/java/security/ |
| D | MessageDigestTest.java | 61 assertTrue("Test should not timeout", es.awaitTermination(1, TimeUnit.MINUTES)); in testMessageDigest_MultipleThreads_Misuse()
|