Home
last modified time | relevance | path

Searched refs:threadStarted (Results 1 – 21 of 21) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DExchangerTest.java77 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException() local
80 threadStarted.countDown(); in testExchange_InterruptedException()
84 await(threadStarted); in testExchange_InterruptedException()
94 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException() local
97 threadStarted.countDown(); in testTimedExchange_InterruptedException()
101 await(threadStarted); in testTimedExchange_InterruptedException()
DThreadPoolExecutorTest.java115 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
119 threadStarted.countDown(); in testGetActiveCount()
123 await(threadStarted); in testGetActiveCount()
186 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
192 threadStarted.countDown(); in testGetCompletedTaskCount()
197 await(threadStarted); in testGetCompletedTaskCount()
387 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
390 threadStarted.countDown(); in testGetPoolSize()
394 await(threadStarted); in testGetPoolSize()
410 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DThreadPoolExecutorSubclassTest.java262 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
266 threadStarted.countDown(); in testGetActiveCount()
270 await(threadStarted); in testGetActiveCount()
333 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
339 threadStarted.countDown(); in testGetCompletedTaskCount()
344 await(threadStarted); in testGetCompletedTaskCount()
534 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
537 threadStarted.countDown(); in testGetPoolSize()
541 await(threadStarted); in testGetPoolSize()
557 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DScheduledExecutorTest.java343 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
347 threadStarted.countDown(); in testGetActiveCount()
351 await(threadStarted); in testGetActiveCount()
363 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
369 threadStarted.countDown(); in testGetCompletedTaskCount()
374 await(threadStarted); in testGetCompletedTaskCount()
427 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
433 threadStarted.countDown(); in testGetPoolSize()
437 await(threadStarted); in testGetPoolSize()
451 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DScheduledExecutorSubclassTest.java399 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
403 threadStarted.countDown(); in testGetActiveCount()
407 await(threadStarted); in testGetActiveCount()
419 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
425 threadStarted.countDown(); in testGetCompletedTaskCount()
430 await(threadStarted); in testGetCompletedTaskCount()
485 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
489 threadStarted.countDown(); in testGetPoolSize()
493 await(threadStarted); in testGetPoolSize()
507 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DBlockingQueueTest.java262 final CountDownLatch threadStarted = new CountDownLatch(1);
265 threadStarted.countDown();
273 await(threadStarted);
303 final CountDownLatch threadStarted = new CountDownLatch(1);
306 threadStarted.countDown();
314 await(threadStarted);
DLinkedTransferQueueTest.java741 final CountDownLatch threadStarted = new CountDownLatch(1); in testWaitingConsumer() local
745 threadStarted.countDown(); in testWaitingConsumer()
753 threadStarted.await(); in testWaitingConsumer()
785 final CountDownLatch threadStarted = new CountDownLatch(1); in testTransfer2() local
789 threadStarted.countDown(); in testTransfer2()
794 threadStarted.await(); in testTransfer2()
DLinkedBlockingDequeTest.java913 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeFirstFromEmptyBlocksInterruptibly() local
916 threadStarted.countDown(); in testTakeFirstFromEmptyBlocksInterruptibly()
924 await(threadStarted); in testTakeFirstFromEmptyBlocksInterruptibly()
954 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeLastFromEmptyBlocksInterruptibly() local
957 threadStarted.countDown(); in testTakeLastFromEmptyBlocksInterruptibly()
965 await(threadStarted); in testTakeLastFromEmptyBlocksInterruptibly()
DAbstractQueuedLongSynchronizerTest.java591 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local
595 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()
599 threadStarted.acquireShared(0); in testAcquireInterruptibly()
DAbstractQueuedSynchronizerTest.java594 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local
598 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()
602 threadStarted.acquireShared(0); in testAcquireInterruptibly()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DExchangerTest.java100 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException() local
103 threadStarted.countDown(); in testExchange_InterruptedException()
107 await(threadStarted); in testExchange_InterruptedException()
117 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException() local
120 threadStarted.countDown(); in testTimedExchange_InterruptedException()
124 await(threadStarted); in testTimedExchange_InterruptedException()
DThreadPoolExecutorTest.java137 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
141 threadStarted.countDown(); in testGetActiveCount()
145 await(threadStarted); in testGetActiveCount()
208 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
214 threadStarted.countDown(); in testGetCompletedTaskCount()
219 await(threadStarted); in testGetCompletedTaskCount()
409 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
412 threadStarted.countDown(); in testGetPoolSize()
416 await(threadStarted); in testGetPoolSize()
432 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DThreadPoolExecutorSubclassTest.java284 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
288 threadStarted.countDown(); in testGetActiveCount()
292 await(threadStarted); in testGetActiveCount()
355 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
361 threadStarted.countDown(); in testGetCompletedTaskCount()
366 await(threadStarted); in testGetCompletedTaskCount()
556 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
559 threadStarted.countDown(); in testGetPoolSize()
563 await(threadStarted); in testGetPoolSize()
579 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DScheduledExecutorSubclassTest.java421 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
425 threadStarted.countDown(); in testGetActiveCount()
429 await(threadStarted); in testGetActiveCount()
441 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
447 threadStarted.countDown(); in testGetCompletedTaskCount()
452 await(threadStarted); in testGetCompletedTaskCount()
507 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
511 threadStarted.countDown(); in testGetPoolSize()
515 await(threadStarted); in testGetPoolSize()
529 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DScheduledExecutorTest.java365 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local
369 threadStarted.countDown(); in testGetActiveCount()
373 await(threadStarted); in testGetActiveCount()
385 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local
391 threadStarted.countDown(); in testGetCompletedTaskCount()
396 await(threadStarted); in testGetCompletedTaskCount()
449 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local
455 threadStarted.countDown(); in testGetPoolSize()
459 await(threadStarted); in testGetPoolSize()
473 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local
[all …]
DBlockingQueueTest.java286 final CountDownLatch threadStarted = new CountDownLatch(1);
289 threadStarted.countDown();
297 await(threadStarted);
327 final CountDownLatch threadStarted = new CountDownLatch(1);
330 threadStarted.countDown();
338 await(threadStarted);
DLinkedTransferQueueTest.java758 final CountDownLatch threadStarted = new CountDownLatch(1); in testWaitingConsumer() local
762 threadStarted.countDown(); in testWaitingConsumer()
770 threadStarted.await(); in testWaitingConsumer()
801 final CountDownLatch threadStarted = new CountDownLatch(1); in testTransfer2() local
805 threadStarted.countDown(); in testTransfer2()
810 threadStarted.await(); in testTransfer2()
DLinkedBlockingDequeTest.java947 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeFirstFromEmptyBlocksInterruptibly() local
950 threadStarted.countDown(); in testTakeFirstFromEmptyBlocksInterruptibly()
958 await(threadStarted); in testTakeFirstFromEmptyBlocksInterruptibly()
988 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeLastFromEmptyBlocksInterruptibly() local
991 threadStarted.countDown(); in testTakeLastFromEmptyBlocksInterruptibly()
999 await(threadStarted); in testTakeLastFromEmptyBlocksInterruptibly()
DAbstractQueuedLongSynchronizerTest.java619 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local
623 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()
627 threadStarted.acquireShared(0); in testAcquireInterruptibly()
DAbstractQueuedSynchronizerTest.java622 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local
626 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()
630 threadStarted.acquireShared(0); in testAcquireInterruptibly()
/libcore/luni/src/test/java/libcore/java/net/
DSocketTimeoutTest.java120 CountDownLatch threadStarted = new CountDownLatch(1); in testSocketWriteNeverTimeouts() local
123 threadStarted.countDown(); in testSocketWriteNeverTimeouts()
137 assertTrue(threadStarted.await(500, TimeUnit.MILLISECONDS)); in testSocketWriteNeverTimeouts()