Home
last modified time | relevance | path

Searched refs:threadsStarted (Results 1 – 11 of 11) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DSynchronousQueueTest.java458 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
463 threadsStarted.await();
470 threadsStarted.await();
484 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
489 threadsStarted.await();
496 threadsStarted.await();
DLinkedBlockingQueueTest.java689 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
693 threadsStarted.await(); in testOfferInExecutor()
700 threadsStarted.await(); in testOfferInExecutor()
712 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
717 threadsStarted.await(); in testPollInExecutor()
724 threadsStarted.await(); in testPollInExecutor()
DArrayBlockingQueueTest.java755 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
759 threadsStarted.await(); in testOfferInExecutor()
766 threadsStarted.await(); in testOfferInExecutor()
779 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
784 threadsStarted.await(); in testPollInExecutor()
791 threadsStarted.await(); in testPollInExecutor()
DLinkedTransferQueueTest.java568 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
573 threadsStarted.await(); in testOfferInExecutor()
579 threadsStarted.await(); in testOfferInExecutor()
592 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
598 threadsStarted.await(); in testPollInExecutor()
605 threadsStarted.await(); in testPollInExecutor()
DPriorityBlockingQueueTest.java601 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
606 threadsStarted.await(); in testPollInExecutor()
613 threadsStarted.await(); in testPollInExecutor()
DDelayQueueTest.java640 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
645 threadsStarted.await(); in testPollInExecutor()
652 threadsStarted.await(); in testPollInExecutor()
DLinkedBlockingDequeTest.java1634 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1638 threadsStarted.await();
1645 threadsStarted.await();
1657 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1662 threadsStarted.await();
1669 threadsStarted.await();
DScheduledExecutorTest.java350 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
357 threadsStarted.countDown(); in testGetLargestPoolSize()
361 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()
DScheduledExecutorSubclassTest.java400 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
407 threadsStarted.countDown(); in testGetLargestPoolSize()
411 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()
DThreadPoolExecutorTest.java300 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
307 threadsStarted.countDown(); in testGetLargestPoolSize()
311 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()
DThreadPoolExecutorSubclassTest.java407 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
414 threadsStarted.countDown(); in testGetLargestPoolSize()
418 assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); in testGetLargestPoolSize()