Searched refs:threadStarted (Results 1 – 11 of 11) sorted by relevance
65 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException() local68 threadStarted.countDown(); in testExchange_InterruptedException()72 await(threadStarted); in testExchange_InterruptedException()82 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException() local85 threadStarted.countDown(); in testTimedExchange_InterruptedException()89 await(threadStarted); in testTimedExchange_InterruptedException()
86 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local92 threadStarted.countDown(); in testGetActiveCount()96 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()147 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local154 threadStarted.countDown(); in testGetCompletedTaskCount()159 await(threadStarted); in testGetCompletedTaskCount()342 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local348 threadStarted.countDown(); in testGetPoolSize()352 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize()368 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
283 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local289 threadStarted.countDown(); in testGetActiveCount()293 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()307 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local314 threadStarted.countDown(); in testGetCompletedTaskCount()319 await(threadStarted); in testGetCompletedTaskCount()376 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local382 threadStarted.countDown(); in testGetPoolSize()386 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize()400 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
333 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local339 threadStarted.countDown(); in testGetActiveCount()343 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()357 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local364 threadStarted.countDown(); in testGetCompletedTaskCount()369 await(threadStarted); in testGetCompletedTaskCount()426 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local432 threadStarted.countDown(); in testGetPoolSize()436 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize()450 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
226 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount() local232 threadStarted.countDown(); in testGetActiveCount()236 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetActiveCount()281 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount() local288 threadStarted.countDown(); in testGetCompletedTaskCount()293 await(threadStarted); in testGetCompletedTaskCount()446 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetPoolSize() local452 threadStarted.countDown(); in testGetPoolSize()456 assertTrue(threadStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetPoolSize()472 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetTaskCount() local[all …]
248 final CountDownLatch threadStarted = new CountDownLatch(1);251 threadStarted.countDown();259 await(threadStarted);289 final CountDownLatch threadStarted = new CountDownLatch(1);292 threadStarted.countDown();300 await(threadStarted);
703 final CountDownLatch threadStarted = new CountDownLatch(1); in testWaitingConsumer() local707 threadStarted.countDown(); in testWaitingConsumer()713 threadStarted.await(); in testWaitingConsumer()743 final CountDownLatch threadStarted = new CountDownLatch(1); in testTransfer2() local747 threadStarted.countDown(); in testTransfer2()752 threadStarted.await(); in testTransfer2()
888 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeFirstFromEmptyBlocksInterruptibly() local891 threadStarted.countDown(); in testTakeFirstFromEmptyBlocksInterruptibly()899 await(threadStarted); in testTakeFirstFromEmptyBlocksInterruptibly()929 final CountDownLatch threadStarted = new CountDownLatch(1); in testTakeLastFromEmptyBlocksInterruptibly() local932 threadStarted.countDown(); in testTakeLastFromEmptyBlocksInterruptibly()940 await(threadStarted); in testTakeLastFromEmptyBlocksInterruptibly()
565 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local569 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()573 threadStarted.acquireShared(0); in testAcquireInterruptibly()
568 final BooleanLatch threadStarted = new BooleanLatch(); in testAcquireInterruptibly() local572 assertTrue(threadStarted.releaseShared(0)); in testAcquireInterruptibly()576 threadStarted.acquireShared(0); in testAcquireInterruptibly()
META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/ ...