| /libcore/ojluni/src/test/java/lang/constant/ |
| D | DynamicConstantDescTest.java | 90 private final CountDownLatch latch; field in DynamicConstantDescTest.Task
92 private Task(final String className, final CountDownLatch latch) { in Task() argument
94 this.latch = latch; in Task()
102 latch.countDown(); in call()
104 latch.await(); in call()
115 private final CountDownLatch latch; field in DynamicConstantDescTest.InvokeOfCanonical
117 private InvokeOfCanonical(final CountDownLatch latch) { in InvokeOfCanonical() argument
118 this.latch = latch; in InvokeOfCanonical()
127 latch.countDown(); in call()
129 latch.await(); in call()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | PendingFuture.java | 51 private CountDownLatch latch; field in PendingFuture
123 if (latch == null) in prepareForWait()
124 latch = new CountDownLatch(1); in prepareForWait()
141 if (latch != null) in setResult()
142 latch.countDown(); in setResult()
159 if (latch != null) in setFailure()
160 latch.countDown(); in setFailure()
180 latch.await(); in get()
197 if (!latch.await(timeout, unit)) throw new TimeoutException(); in get()
250 if (latch != null) in cancel()
[all …]
|
| /libcore/luni/src/test/java/libcore/java/lang/ref/ |
| D | FinalizeTest.java | 112 CountDownLatch latch = new CountDownLatch(3); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline() local
113 createSlowFinalizer( 1, latch); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
114 createSlowFinalizer(1000, latch); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
115 createSlowFinalizer(8000, latch); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
117 latch.await(); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
120 public void createSlowFinalizer(final long millis, final CountDownLatch latch) { in createSlowFinalizer() argument
125 latch.countDown(); in createSlowFinalizer()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | ServerSocketChannelTest.java | 128 private final CountDownLatch latch; field in ServerSocketChannelTest.CountingServer
131 private CountingServer(ServerSocketChannel channel, CountDownLatch latch) { in CountingServer() argument
133 this.latch = latch; in CountingServer()
141 latch.countDown(); in call()
183 CountDownLatch latch = new CountDownLatch(1); in bind_loopback() local
184 Future<Integer> countFuture = executor.submit(new CountingServer(ssc, latch)); in bind_loopback()
187 latch.await(); in bind_loopback()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | JSR166TestCase.java | 886 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner() argument
887 return new PoolCleanerWithReleaser(pool, releaser(latch)); in cleaner()
890 Runnable releaser(final CountDownLatch latch) { in releaser() argument
892 do { latch.countDown(); } in releaser()
893 while (latch.getCount() > 0); in releaser()
1471 public Callable<String> latchAwaitingStringTask(final CountDownLatch latch) {
1475 latch.await();
1481 public Runnable countDowner(final CountDownLatch latch) {
1484 latch.countDown();
1492 final CountDownLatch latch;
[all …]
|
| D | PhaserTest.java | 653 final CountDownLatch latch = new CountDownLatch(1);
658 latch.countDown();
660 await(latch);
664 await(latch);
666 latch.countDown();
|
| D | ForkJoinPoolTest.java | 657 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny4() local
661 l.add(latchAwaitingStringTask(latch)); in testInvokeAny4()
667 latch.countDown(); in testInvokeAny4()
825 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
829 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
835 latch.countDown(); in testTimedInvokeAny3()
|
| D | ScheduledExecutorSubclassTest.java | 946 final CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
950 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
956 latch.countDown(); in testInvokeAny3()
1111 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1115 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1121 latch.countDown(); in testTimedInvokeAny3()
|
| D | ScheduledExecutorTest.java | 895 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
899 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
905 latch.countDown(); in testInvokeAny3()
1060 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1064 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1070 latch.countDown(); in testTimedInvokeAny3()
|
| D | ThreadPoolExecutorTest.java | 1515 final CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1522 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1528 latch.countDown(); in testInvokeAny3()
1714 final CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1721 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1727 latch.countDown(); in testTimedInvokeAny3()
|
| D | ThreadPoolExecutorSubclassTest.java | 1508 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1515 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1521 latch.countDown(); in testInvokeAny3()
1707 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1714 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1720 latch.countDown(); in testTimedInvokeAny3()
|
| /libcore/luni/src/test/java/libcore/java/security/ |
| D | MessageDigestTest.java | 39 final CountDownLatch latch = new CountDownLatch(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse() local
48 latch.countDown(); in testMessageDigest_MultipleThreads_Misuse()
49 latch.await(); in testMessageDigest_MultipleThreads_Misuse()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | JSR166TestCase.java | 1165 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner() argument
1166 return new PoolCleanerWithReleaser(pool, releaser(latch)); in cleaner()
1169 Runnable releaser(final CountDownLatch latch) { in releaser() argument
1171 do { latch.countDown(); } in releaser()
1172 while (latch.getCount() > 0); in releaser()
1888 public Callable<String> latchAwaitingStringTask(final CountDownLatch latch) {
1892 latch.await();
1898 public Runnable countDowner(final CountDownLatch latch) {
1901 latch.countDown();
1909 final CountDownLatch latch;
[all …]
|
| D | PhaserTest.java | 724 final CountDownLatch latch = new CountDownLatch(1);
729 latch.countDown();
731 await(latch);
735 await(latch);
737 latch.countDown();
|
| D | ForkJoinPoolTest.java | 718 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny4() local
722 l.add(latchAwaitingStringTask(latch)); in testInvokeAny4()
728 latch.countDown(); in testInvokeAny4()
897 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
901 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
907 latch.countDown(); in testTimedInvokeAny3()
|
| D | ScheduledExecutorTest.java | 1094 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1098 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1104 latch.countDown(); in testInvokeAny3()
1270 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1274 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1280 latch.countDown(); in testTimedInvokeAny3()
|
| D | ScheduledExecutorSubclassTest.java | 1024 final CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1028 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1034 latch.countDown(); in testInvokeAny3()
1200 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1204 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1210 latch.countDown(); in testTimedInvokeAny3()
|
| D | ThreadPoolExecutorSubclassTest.java | 1616 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1623 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1629 latch.countDown(); in testInvokeAny3()
1826 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1833 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1839 latch.countDown(); in testTimedInvokeAny3()
|
| D | ThreadPoolExecutorTest.java | 1625 final CountDownLatch latch = new CountDownLatch(1); in testInvokeAny3() local
1632 l.add(latchAwaitingStringTask(latch)); in testInvokeAny3()
1638 latch.countDown(); in testInvokeAny3()
1835 final CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3() local
1842 l.add(latchAwaitingStringTask(latch)); in testTimedInvokeAny3()
1848 latch.countDown(); in testTimedInvokeAny3()
|
| /libcore/ojluni/src/test/java/security/KeyAgreement/ |
| D | MultiThreadTest.java | 124 CountDownLatch latch = new CountDownLatch(THREAD_COUNT); in runTest() local
136 latch.countDown(); in runTest()
142 latch.await(); in runTest()
|
| /libcore/ojluni/src/test/java/util/Timer/ |
| D | Args.java | 62 TimerTask counter(final CountDownLatch latch) { in counter() argument
64 if (latch.getCount() == 0) in counter()
66 latch)); in counter()
67 latch.countDown(); in counter()
|
| /libcore/luni/src/test/java/libcore/java/lang/ |
| D | ThreadTest.java | 178 final CountDownLatch latch = new CountDownLatch(1); in setPriority_starting() local
180 @Override public void run() { try { latch.await(); } catch (Exception e) { } } in setPriority_starting()
190 latch.countDown(); in setPriority_starting()
196 final CountDownLatch latch = new CountDownLatch(1); in setPriority_started() local
198 @Override public void run() { try { latch.await(); } catch (Exception e) { } } in setPriority_started()
203 latch.countDown(); in setPriority_started()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| D | TimerTest.java | 882 final CountDownLatch latch = new CountDownLatch(10); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_oldBehavior() local
898 latch.countDown(); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_oldBehavior()
908 latch.await(1_100, TimeUnit.MILLISECONDS)); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_oldBehavior()
926 final CountDownLatch latch = new CountDownLatch(6); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_newBehavior() local
942 latch.countDown(); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_newBehavior()
951 latch.await(1_000, TimeUnit.MILLISECONDS); in test_scheduleAtFixedRateLjava_util_TimerTaskJJ_SkipMultipleMissedFixedRateTasks_newBehavior()
1281 CountDownLatch latch = new CountDownLatch(1); field in TimerTest.SwallowUncaughtExceptionHandler
1284 latch.countDown(); in uncaughtException()
1288 if(!latch.await(millis, TimeUnit.MILLISECONDS)) { in waitForException()
|