Home
last modified time | relevance | path

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

/libcore/jsr166-tests/src/test/java/jsr166/
DCollection8Test.java84 final CountDownLatch threadsStarted = new CountDownLatch(2); in testForEachConcurrentStressTest() local
86 threadsStarted.countDown(); in testForEachConcurrentStressTest()
90 threadsStarted.countDown(); in testForEachConcurrentStressTest()
DSynchronousQueueTest.java480 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
487 threadsStarted.await();
494 threadsStarted.await();
507 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
513 threadsStarted.await();
520 threadsStarted.await();
DLinkedBlockingQueueTest.java730 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
736 threadsStarted.await(); in testOfferInExecutor()
743 threadsStarted.await(); in testOfferInExecutor()
754 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
760 threadsStarted.await(); in testPollInExecutor()
767 threadsStarted.await(); in testPollInExecutor()
DArrayBlockingQueueTest.java796 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
802 threadsStarted.await(); in testOfferInExecutor()
809 threadsStarted.await(); in testOfferInExecutor()
821 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
827 threadsStarted.await(); in testPollInExecutor()
834 threadsStarted.await(); in testPollInExecutor()
DLinkedTransferQueueTest.java603 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
609 threadsStarted.await(); in testOfferInExecutor()
617 threadsStarted.await(); in testOfferInExecutor()
629 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
636 threadsStarted.await(); in testPollInExecutor()
645 threadsStarted.await(); in testPollInExecutor()
DScheduledExecutorSubclassTest.java462 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
467 threadsStarted.countDown(); in testGetLargestPoolSize()
471 await(threadsStarted); in testGetLargestPoolSize()
724 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
726 threadsStarted.countDown(); in testShutdownNow()
734 await(threadsStarted); in testShutdownNow()
DScheduledExecutorTest.java404 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
411 threadsStarted.countDown(); in testGetLargestPoolSize()
415 await(threadsStarted); in testGetLargestPoolSize()
673 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
675 threadsStarted.countDown(); in testShutdownNow()
683 await(threadsStarted); in testShutdownNow()
DPriorityBlockingQueueTest.java631 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
637 threadsStarted.await(); in testPollInExecutor()
644 threadsStarted.await(); in testPollInExecutor()
DDelayQueueTest.java674 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
680 threadsStarted.await(); in testPollInExecutor()
687 threadsStarted.await(); in testPollInExecutor()
DThreadPoolExecutorSubclassTest.java490 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
494 threadsStarted.countDown(); in testGetLargestPoolSize()
498 await(threadsStarted); in testGetLargestPoolSize()
772 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
774 threadsStarted.countDown(); in testShutdownNow()
782 await(threadsStarted); in testShutdownNow()
DLinkedBlockingDequeTest.java1684 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1690 threadsStarted.await();
1697 threadsStarted.await();
1708 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1714 threadsStarted.await();
1721 threadsStarted.await();
DThreadPoolExecutorTest.java343 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
347 threadsStarted.countDown(); in testGetLargestPoolSize()
351 await(threadsStarted); in testGetLargestPoolSize()
657 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
659 threadsStarted.countDown(); in testShutdownNow()
667 await(threadsStarted); in testShutdownNow()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DSynchronousQueueTest.java500 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
507 threadsStarted.await();
514 threadsStarted.await();
527 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
533 threadsStarted.await();
540 threadsStarted.await();
DLinkedBlockingQueueTest.java760 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
766 threadsStarted.await(); in testOfferInExecutor()
773 threadsStarted.await(); in testOfferInExecutor()
784 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
790 threadsStarted.await(); in testPollInExecutor()
797 threadsStarted.await(); in testPollInExecutor()
DCollection8Test.java686 final CountDownLatch threadsStarted = new CountDownLatch(2);
688 threadsStarted.countDown();
692 threadsStarted.countDown();
815 final Phaser threadsStarted = new Phaser(1); // register this thread
853 threadsStarted.arriveAndAwaitAdvance();
860 threadsStarted.bulkRegister(tasks.size());
864 threadsStarted.arriveAndDeregister();
DLinkedTransferQueueTest.java620 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
626 threadsStarted.await(); in testOfferInExecutor()
634 threadsStarted.await(); in testOfferInExecutor()
646 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
653 threadsStarted.await(); in testPollInExecutor()
662 threadsStarted.await(); in testPollInExecutor()
DArrayBlockingQueueTest.java840 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testOfferInExecutor() local
846 threadsStarted.await(); in testOfferInExecutor()
853 threadsStarted.await(); in testOfferInExecutor()
865 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
871 threadsStarted.await(); in testPollInExecutor()
878 threadsStarted.await(); in testPollInExecutor()
DScheduledExecutorSubclassTest.java484 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
489 threadsStarted.countDown(); in testGetLargestPoolSize()
493 await(threadsStarted); in testGetLargestPoolSize()
746 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
748 threadsStarted.countDown(); in testShutdownNow()
756 await(threadsStarted); in testShutdownNow()
DScheduledExecutorTest.java426 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
433 threadsStarted.countDown(); in testGetLargestPoolSize()
437 await(threadsStarted); in testGetLargestPoolSize()
694 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
696 threadsStarted.countDown(); in testShutdownNow()
704 await(threadsStarted); in testShutdownNow()
DStampedLockTest.java337 CountDownLatch threadsStarted = new CountDownLatch(n); in assertThrowInterruptedExceptionWhenInterrupted() local
344 threadsStarted.countDown(); in assertThrowInterruptedExceptionWhenInterrupted()
356 await(threadsStarted); in assertThrowInterruptedExceptionWhenInterrupted()
563 final CountDownLatch threadsStarted = new CountDownLatch(2); in testReadAfterWriteLock() local
567 threadsStarted.countDown(); in testReadAfterWriteLock()
576 await(threadsStarted); in testReadAfterWriteLock()
DPriorityBlockingQueueTest.java664 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
670 threadsStarted.await(); in testPollInExecutor()
677 threadsStarted.await(); in testPollInExecutor()
DDelayQueueTest.java682 final CheckedBarrier threadsStarted = new CheckedBarrier(2); in testPollInExecutor() local
688 threadsStarted.await(); in testPollInExecutor()
695 threadsStarted.await(); in testPollInExecutor()
DLinkedBlockingDequeTest.java1718 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1724 threadsStarted.await();
1731 threadsStarted.await();
1742 final CheckedBarrier threadsStarted = new CheckedBarrier(2);
1748 threadsStarted.await();
1755 threadsStarted.await();
DThreadPoolExecutorSubclassTest.java512 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
516 threadsStarted.countDown(); in testGetLargestPoolSize()
520 await(threadsStarted); in testGetLargestPoolSize()
794 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
796 threadsStarted.countDown(); in testShutdownNow()
804 await(threadsStarted); in testShutdownNow()
DThreadPoolExecutorTest.java365 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize() local
369 threadsStarted.countDown(); in testGetLargestPoolSize()
373 await(threadsStarted); in testGetLargestPoolSize()
679 final CountDownLatch threadsStarted = new CountDownLatch(poolSize); in testShutdownNow() local
681 threadsStarted.countDown(); in testShutdownNow()
689 await(threadsStarted); in testShutdownNow()