Home
last modified time | relevance | path

Searched refs:awaitTermination (Results 1 – 25 of 76) sorted by relevance

1234

/libcore/jsr166-tests/src/test/java/jsr166/
DCyclicBarrierTest.java122 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 …]
DExchangerTest.java48 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()
DReentrantReadWriteLockTest.java326 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 …]
DAbstractQueuedLongSynchronizerTest.java317 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 …]
DAbstractQueuedSynchronizerTest.java320 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 …]
DLockSupportTest.java126 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()
DReentrantLockTest.java258 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 …]
DCountDownLatchTest.java83 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()
DStampedLockTest.java297 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 …]
DSemaphoreTest.java272 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 …]
DPhaserTest.java319 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 …]
DFutureTaskTest.java432 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 …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCyclicBarrierTest.java143 awaitTermination(t); in testTwoParties()
168 awaitTermination(t1); in testAwait1_Interrupted_BrokenBarrier()
169 awaitTermination(t2); in testAwait1_Interrupted_BrokenBarrier()
194 awaitTermination(t1); in testAwait2_Interrupted_BrokenBarrier()
195 awaitTermination(t2); in testAwait2_Interrupted_BrokenBarrier()
213 awaitTermination(t); in testAwait3_TimeoutException()
240 awaitTermination(t1); in testAwait4_Timeout_BrokenBarrier()
241 awaitTermination(t2); in testAwait4_Timeout_BrokenBarrier()
268 awaitTermination(t1); in testAwait5_Timeout_BrokenBarrier()
269 awaitTermination(t2); in testAwait5_Timeout_BrokenBarrier()
[all …]
DExchangerTest.java71 awaitTermination(t1); in testExchange()
72 awaitTermination(t2); in testExchange()
91 awaitTermination(t1); in testTimedExchange()
92 awaitTermination(t2); in testTimedExchange()
109 awaitTermination(t); in testExchange_InterruptedException()
126 awaitTermination(t); in testTimedExchange_InterruptedException()
144 awaitTermination(t); in testExchange_TimeoutException()
175 awaitTermination(t1); in testReplacementAfterExchange()
177 awaitTermination(t2); in testReplacementAfterExchange()
178 awaitTermination(t3); in testReplacementAfterExchange()
DReentrantReadWriteLockTest.java349 awaitTermination(t); in testWriteLockInterruptibly_Interruptible()
369 awaitTermination(t); in testWriteTryLock_Interruptible()
389 awaitTermination(t); in testReadLockInterruptibly_Interruptible()
409 awaitTermination(t); in testReadTryLock_Interruptible()
443 awaitTermination(t); in testWriteTryLockWhenLocked()
461 awaitTermination(t); in testReadTryLockWhenLocked()
483 awaitTermination(t); in testMultipleReadLocks()
508 awaitTermination(t); in testWriteAfterReadLock()
528 awaitTermination(t1); in testWriteAfterMultipleReadLocks()
543 awaitTermination(t2); in testWriteAfterMultipleReadLocks()
[all …]
DAbstractQueuedLongSynchronizerTest.java345 awaitTermination(t1); in testHasQueuedThreads()
348 awaitTermination(t2); in testHasQueuedThreads()
382 awaitTermination(t1); in testIsQueued()
386 awaitTermination(t2); in testIsQueued()
405 awaitTermination(t1); in testGetFirstQueuedThread()
408 awaitTermination(t2); in testGetFirstQueuedThread()
427 awaitTermination(t1); in testHasContended()
430 awaitTermination(t2); in testHasContended()
455 awaitTermination(t1); in testGetQueuedThreads()
458 awaitTermination(t2); in testGetQueuedThreads()
[all …]
DAbstractQueuedSynchronizerTest.java348 awaitTermination(t1); in testHasQueuedThreads()
351 awaitTermination(t2); in testHasQueuedThreads()
385 awaitTermination(t1); in testIsQueued()
389 awaitTermination(t2); in testIsQueued()
408 awaitTermination(t1); in testGetFirstQueuedThread()
411 awaitTermination(t2); in testGetFirstQueuedThread()
430 awaitTermination(t1); in testHasContended()
433 awaitTermination(t2); in testHasContended()
458 awaitTermination(t1); in testGetQueuedThreads()
461 awaitTermination(t2); in testGetQueuedThreads()
[all …]
DLockSupportTest.java150 awaitTermination(t); in testParkBeforeUnpark()
188 awaitTermination(t); in testParkAfterUnpark()
226 awaitTermination(t); in testParkBeforeInterrupt()
266 awaitTermination(t); in testParkAfterInterrupt()
296 awaitTermination(t); in testParkTimesOut()
341 awaitTermination(t); in testGetBlocker()
378 awaitTermination(t); in testPark0()
402 awaitTermination(t); in testParkNeg()
DReentrantLockTest.java281 awaitTermination(t1); in testHasQueuedThreads()
284 awaitTermination(t2); in testHasQueuedThreads()
306 awaitTermination(t1); in testGetQueueLength()
309 awaitTermination(t2); in testGetQueueLength()
347 awaitTermination(t1); in testHasQueuedThread()
351 awaitTermination(t2); in testHasQueuedThread()
378 awaitTermination(t1); in testGetQueuedThreads()
383 awaitTermination(t2); in testGetQueuedThreads()
402 awaitTermination(t); in testTryLock_Interruptible()
419 awaitTermination(t); in testTryLockWhenLocked()
[all …]
DCountDownLatchTest.java106 awaitTermination(t); in testAwait()
131 awaitTermination(t); in testTimedAwait()
162 awaitTermination(t); in testAwait_Interruptible()
193 awaitTermination(t); in testTimedAwait_Interruptible()
208 awaitTermination(t); in testAwaitTimeout()
DSemaphoreTest.java295 awaitTermination(t); in testInterruptible()
337 awaitTermination(t1); in testUninterruptible()
338 awaitTermination(t2); in testUninterruptible()
357 awaitTermination(t1); in testHasQueuedThreads()
360 awaitTermination(t2); in testHasQueuedThreads()
380 awaitTermination(t1); in testGetQueueLength()
383 awaitTermination(t2); in testGetQueueLength()
405 awaitTermination(t1); in testGetQueuedThreads()
409 awaitTermination(t2); in testGetQueuedThreads()
515 awaitTermination(t); in testSerialization()
[all …]
DPhaserTest.java343 awaitTermination(thread); in testArrive2()
459 awaitTermination(t);
527 awaitTermination(t1);
528 awaitTermination(t2);
556 awaitTermination(t);
585 awaitTermination(t);
615 awaitTermination(t);
641 awaitTermination(t);
664 awaitTermination(thread);
695 awaitTermination(thread);
[all …]
DFutureTaskTest.java455 awaitTermination(t); in testCancelInterrupt()
502 awaitTermination(t); in testCancelInterrupt_ThrowsSecurityException()
530 awaitTermination(t); in testCancelInterrupt_taskFails()
558 awaitTermination(t); in testCancelNoInterrupt()
599 awaitTermination(t1); in testGetRun()
600 awaitTermination(t2); in testGetRun()
639 awaitTermination(t1); in testGetSet()
640 awaitTermination(t2); in testGetSet()
688 awaitTermination(t1); in testTimedGet_Cancellation()
689 awaitTermination(t2); in testTimedGet_Cancellation()
[all …]
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DExecutorServiceAutoCloseable.java36 if(!service.awaitTermination(5000, TimeUnit.MILLISECONDS)) { in close()
38 service.awaitTermination(1000, TimeUnit.MILLISECONDS); in close()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DAsynchronousChannelGroupTest.java106 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()

1234