| /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 | 324 awaitTermination(t); in testWriteLockInterruptibly_Interruptible()
344 awaitTermination(t); in testWriteTryLock_Interruptible()
364 awaitTermination(t); in testReadLockInterruptibly_Interruptible()
384 awaitTermination(t); in testReadTryLock_Interruptible()
418 awaitTermination(t); in testWriteTryLockWhenLocked()
436 awaitTermination(t); in testReadTryLockWhenLocked()
458 awaitTermination(t); in testMultipleReadLocks()
483 awaitTermination(t); in testWriteAfterReadLock()
503 awaitTermination(t1); in testWriteAfterMultipleReadLocks()
518 awaitTermination(t2); in testWriteAfterMultipleReadLocks()
[all …]
|
| D | AbstractQueuedSynchronizerTest.java | 312 awaitTermination(t1); in testHasQueuedThreads()
315 awaitTermination(t2); in testHasQueuedThreads()
349 awaitTermination(t1); in testIsQueued()
353 awaitTermination(t2); in testIsQueued()
372 awaitTermination(t1); in testGetFirstQueuedThread()
375 awaitTermination(t2); in testGetFirstQueuedThread()
394 awaitTermination(t1); in testHasContended()
397 awaitTermination(t2); in testHasContended()
422 awaitTermination(t1); in testGetQueuedThreads()
425 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | AbstractQueuedLongSynchronizerTest.java | 309 awaitTermination(t1); in testHasQueuedThreads()
312 awaitTermination(t2); in testHasQueuedThreads()
346 awaitTermination(t1); in testIsQueued()
350 awaitTermination(t2); in testIsQueued()
369 awaitTermination(t1); in testGetFirstQueuedThread()
372 awaitTermination(t2); in testGetFirstQueuedThread()
391 awaitTermination(t1); in testHasContended()
394 awaitTermination(t2); in testHasContended()
419 awaitTermination(t1); in testGetQueuedThreads()
422 awaitTermination(t2); in testGetQueuedThreads()
[all …]
|
| D | LockSupportTest.java | 120 awaitTermination(t); in testParkBeforeUnpark()
158 awaitTermination(t); in testParkAfterUnpark()
196 awaitTermination(t); in testParkBeforeInterrupt()
236 awaitTermination(t); in testParkAfterInterrupt()
266 awaitTermination(t); in testParkTimesOut()
311 awaitTermination(t); in testGetBlocker()
348 awaitTermination(t); in testPark0()
372 awaitTermination(t); in testParkNeg()
|
| 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 | ReentrantLockTest.java | 256 awaitTermination(t1); in testHasQueuedThreads()
259 awaitTermination(t2); in testHasQueuedThreads()
281 awaitTermination(t1); in testGetQueueLength()
284 awaitTermination(t2); in testGetQueueLength()
322 awaitTermination(t1); in testHasQueuedThread()
326 awaitTermination(t2); in testHasQueuedThread()
353 awaitTermination(t1); in testGetQueuedThreads()
358 awaitTermination(t2); in testGetQueuedThreads()
377 awaitTermination(t); in testTryLock_Interruptible()
394 awaitTermination(t); in testTryLockWhenLocked()
[all …]
|
| D | SemaphoreTest.java | 271 awaitTermination(t); in testInterruptible()
313 awaitTermination(t1); in testUninterruptible()
314 awaitTermination(t2); in testUninterruptible()
333 awaitTermination(t1); in testHasQueuedThreads()
336 awaitTermination(t2); in testHasQueuedThreads()
356 awaitTermination(t1); in testGetQueueLength()
359 awaitTermination(t2); in testGetQueueLength()
381 awaitTermination(t1); in testGetQueuedThreads()
385 awaitTermination(t2); in testGetQueuedThreads()
486 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 | 252 awaitTermination(t); in testTimedPollWithOffer()
274 awaitTermination(t);
293 awaitTermination(t);
315 awaitTermination(t);
334 awaitTermination(t);
|
| D | LinkedTransferQueueTest.java | 236 awaitTermination(t); in testBlockingTake()
306 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
330 awaitTermination(t, MEDIUM_DELAY_MS); in testTimedPollAfterInterrupt()
702 awaitTermination(t, MEDIUM_DELAY_MS); in testDrainToWithActivePut()
753 awaitTermination(t, MEDIUM_DELAY_MS); in testWaitingConsumer()
788 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer2()
844 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer4()
867 awaitTermination(t, MEDIUM_DELAY_MS); in testTransfer5()
911 awaitTermination(t, MEDIUM_DELAY_MS); in testTryTransfer3()
933 awaitTermination(t, MEDIUM_DELAY_MS); in testTryTransfer4()
[all …]
|
| D | LinkedBlockingDequeTest.java | 604 awaitTermination(t); in testBlockingPut()
639 awaitTermination(t); in testPutWithTake()
666 awaitTermination(t); in testTimedOffer()
709 awaitTermination(t); in testBlockingTake()
777 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
836 awaitTermination(t); in testBlockingPutFirst()
871 awaitTermination(t); in testPutFirstWithTake()
898 awaitTermination(t); in testTimedOfferFirst()
930 awaitTermination(t); in testTakeFirstFromEmptyBlocksInterruptibly()
949 awaitTermination(t); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
|
| D | SynchronousQueueTest.java | 148 awaitTermination(t); in testBlockingPut()
182 awaitTermination(t); in testPutWithTake()
209 awaitTermination(t); in testTimedOffer()
291 awaitTermination(t); in testTimedPollWithOffer()
579 awaitTermination(t);
605 awaitTermination(t1);
606 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 | 238 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
239 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
240 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
241 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
242 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
243 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
246 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
251 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
255 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
|
| D | ThreadPoolExecutorTest.java | 437 assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); in testAwaitTermination_timesOut()
438 assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); in testAwaitTermination_timesOut()
439 assertFalse(p.awaitTermination(-1L, NANOSECONDS)); in testAwaitTermination_timesOut()
440 assertFalse(p.awaitTermination(-1L, MILLISECONDS)); in testAwaitTermination_timesOut()
441 assertFalse(p.awaitTermination(0L, NANOSECONDS)); in testAwaitTermination_timesOut()
442 assertFalse(p.awaitTermination(0L, MILLISECONDS)); in testAwaitTermination_timesOut()
445 assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); in testAwaitTermination_timesOut()
450 assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); in testAwaitTermination_timesOut()
454 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testAwaitTermination_timesOut()
482 assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); in testIsTerminated()
[all …]
|
| D | ThreadLocalRandomTest.java | 333 awaitTermination(first);
339 awaitTermination(t);
|
| D | LinkedBlockingQueueTest.java | 293 awaitTermination(t); in testBlockingPut()
328 awaitTermination(t); in testPutWithTake()
355 awaitTermination(t); in testTimedOffer()
398 awaitTermination(t); in testBlockingTake()
466 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
|
| D | PriorityBlockingQueueTest.java | 290 awaitTermination(t); in testPutWithTake()
308 awaitTermination(t); in testTimedOffer()
351 awaitTermination(t); in testBlockingTake()
419 awaitTermination(t, MEDIUM_DELAY_MS); in testInterruptedTimedPoll()
|
| D | DelayQueueTest.java | 323 awaitTermination(t); in testPutWithTake()
340 awaitTermination(t); in testTimedOffer()
383 awaitTermination(t); in testBlockingTake()
455 awaitTermination(t); in testInterruptedTimedPoll()
|
| D | JSR166TestCase.java | 406 if (!exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS)) in joinPool()
705 void awaitTermination(Thread t, long timeoutMillis) { in awaitTermination() method in JSR166TestCase
723 void awaitTermination(Thread t) { in awaitTermination() method in JSR166TestCase
724 awaitTermination(t, LONG_DELAY_MS); in awaitTermination()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ExecutorService.java | 171 boolean awaitTermination(long timeout, TimeUnit unit) in awaitTermination() method
|
| D | Executors.java | 589 public boolean awaitTermination(long timeout, TimeUnit unit)
591 return e.awaitTermination(timeout, unit);
|