Searched refs:threadStarted (Results 1 – 11 of 11) sorted by relevance
77 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException() local80 threadStarted.countDown(); in testExchange_InterruptedException()84 await(threadStarted); in testExchange_InterruptedException()94 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException() local97 threadStarted.countDown(); in testTimedExchange_InterruptedException()101 await(threadStarted); in testTimedExchange_InterruptedException()
115 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local119 threadStarted.countDown(); in testGetActiveCount()123 await(threadStarted); in testGetActiveCount()186 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local192 threadStarted.countDown(); in testGetCompletedTaskCount()197 await(threadStarted); in testGetCompletedTaskCount()387 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local390 threadStarted.countDown(); in testGetPoolSize()394 await(threadStarted); in testGetPoolSize()410 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
262 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local266 threadStarted.countDown(); in testGetActiveCount()270 await(threadStarted); in testGetActiveCount()333 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local339 threadStarted.countDown(); in testGetCompletedTaskCount()344 await(threadStarted); in testGetCompletedTaskCount()534 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local537 threadStarted.countDown(); in testGetPoolSize()541 await(threadStarted); in testGetPoolSize()557 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
343 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local347 threadStarted.countDown(); in testGetActiveCount()351 await(threadStarted); in testGetActiveCount()363 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local369 threadStarted.countDown(); in testGetCompletedTaskCount()374 await(threadStarted); in testGetCompletedTaskCount()427 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local433 threadStarted.countDown(); in testGetPoolSize()437 await(threadStarted); in testGetPoolSize()451 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
399 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local403 threadStarted.countDown(); in testGetActiveCount()407 await(threadStarted); in testGetActiveCount()419 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local425 threadStarted.countDown(); in testGetCompletedTaskCount()430 await(threadStarted); in testGetCompletedTaskCount()485 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local489 threadStarted.countDown(); in testGetPoolSize()493 await(threadStarted); in testGetPoolSize()507 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
262 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);
741 final CountDownLatch threadStarted = new CountDownLatch(1); in testWaitingConsumer() local745 threadStarted.countDown(); in testWaitingConsumer()753 threadStarted.await(); in testWaitingConsumer()785 final CountDownLatch threadStarted = new CountDownLatch(1); in testTransfer2() local789 threadStarted.countDown(); in testTransfer2()794 threadStarted.await(); in testTransfer2()
913 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeFirstFromEmptyBlocksInterruptibly() local916 threadStarted.countDown(); in testTakeFirstFromEmptyBlocksInterruptibly()924 await(threadStarted); in testTakeFirstFromEmptyBlocksInterruptibly()954 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeLastFromEmptyBlocksInterruptibly() local957 threadStarted.countDown(); in testTakeLastFromEmptyBlocksInterruptibly()965 await(threadStarted); in testTakeLastFromEmptyBlocksInterruptibly()
591 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local595 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()599 threadStarted.acquireShared(0); in testAcquireInterruptibly()
594 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local598 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()602 threadStarted.acquireShared(0); in testAcquireInterruptibly()
120 CountDownLatch threadStarted = new CountDownLatch(1); in testSocketWriteNeverTimeouts() local123 threadStarted.countDown(); in testSocketWriteNeverTimeouts()137 assertTrue(threadStarted.await(500, TimeUnit.MILLISECONDS)); in testSocketWriteNeverTimeouts()