Home
last modified time | relevance | path

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

1234

/libcore/jsr166-tests/src/test/java/jsr166/
DCountDownLatchTest.java13 import java.util.concurrent.CountDownLatch;
34 new CountDownLatch(-1); in testConstructor()
43 final CountDownLatch l = new CountDownLatch(2); in testGetCount()
53 final CountDownLatch l = new CountDownLatch(1); in testCountDown()
65 final CountDownLatch l = new CountDownLatch(2); in testAwait()
66 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testAwait()
90 final CountDownLatch l = new CountDownLatch(2); in testTimedAwait()
91 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testTimedAwait()
115 final CountDownLatch l = new CountDownLatch(1); in testAwait_Interruptible()
116 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible()
[all …]
DScheduledExecutorTest.java21 import java.util.concurrent.CountDownLatch;
55 final CountDownLatch done = new CountDownLatch(1); in testExecute()
70 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
91 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
111 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
133 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
164 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
195 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
340 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
343 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
[all …]
DScheduledExecutorSubclassTest.java19 import java.util.concurrent.CountDownLatch;
112 final CountDownLatch done = new CountDownLatch(1); in testExecute()
124 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
147 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
167 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
189 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
220 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
251 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
396 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
399 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
[all …]
DThreadPoolExecutorTest.java21 import java.util.concurrent.CountDownLatch;
51 final CountDownLatch beforeCalled = new CountDownLatch(1);
52 final CountDownLatch afterCalled = new CountDownLatch(1);
53 final CountDownLatch terminatedCalled = new CountDownLatch(1);
96 final CountDownLatch done = new CountDownLatch(1); in testExecute()
109 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
115 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
186 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
187 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
188 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DThreadPoolExecutorSubclassTest.java20 import java.util.concurrent.CountDownLatch;
198 final CountDownLatch beforeCalled = new CountDownLatch(1);
199 final CountDownLatch afterCalled = new CountDownLatch(1);
200 final CountDownLatch terminatedCalled = new CountDownLatch(1);
243 final CountDownLatch done = new CountDownLatch(1); in testExecute()
256 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
262 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
333 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
334 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
335 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DExchangerTest.java13 import java.util.concurrent.CountDownLatch;
77 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException()
94 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException()
129 final CountDownLatch exchanged = new CountDownLatch(2); in testReplacementAfterExchange()
130 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange()
DLockSupportTest.java14 import java.util.concurrent.CountDownLatch;
117 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkBeforeUnpark()
151 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkAfterUnpark()
189 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt()
227 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt()
298 final CountDownLatch started = new CountDownLatch(1); in testGetBlocker()
DFutureTaskTest.java20 import java.util.concurrent.CountDownLatch;
416 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt()
446 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
447 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
490 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_taskFails()
519 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelNoInterrupt()
520 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelNoInterrupt()
547 final CountDownLatch pleaseRun = new CountDownLatch(2); in testGetRun()
586 final CountDownLatch pleaseSet = new CountDownLatch(2); in testGetSet()
631 final CountDownLatch pleaseCancel = new CountDownLatch(3); in testTimedGet_Cancellation()
[all …]
DLinkedBlockingDequeTest.java20 import java.util.concurrent.CountDownLatch;
577 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
614 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
615 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
647 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
683 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
755 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
807 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPutFirst()
844 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutFirstWithTake()
845 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutFirstWithTake()
[all …]
DPhaserTest.java14 import java.util.concurrent.CountDownLatch;
462 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
516 final CountDownLatch pleaseArrive = new CountDownLatch(1);
545 final CountDownLatch pleaseArrive = new CountDownLatch(1);
574 final CountDownLatch pleaseArrive = new CountDownLatch(1);
600 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
653 final CountDownLatch latch = new CountDownLatch(1);
726 final CountDownLatch pleaseForceTermination = new CountDownLatch(2);
770 final CountDownLatch pleaseArrive = new CountDownLatch(THREADS);
DExecutorsTest.java21 import java.util.concurrent.CountDownLatch;
205 final CountDownLatch proceed = new CountDownLatch(1); in testNewSingleThreadScheduledExecutor()
229 final CountDownLatch proceed = new CountDownLatch(1); in testNewScheduledThreadPool()
255 final CountDownLatch proceed = new CountDownLatch(1); in testUnconfigurableScheduledExecutorService()
309 final CountDownLatch done = new CountDownLatch(1); in testDefaultThreadFactory()
342 final CountDownLatch done = new CountDownLatch(1); in testPrivilegedThreadFactory()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCountDownLatchTest.java39 import java.util.concurrent.CountDownLatch;
57 new CountDownLatch(-1); in testConstructor()
66 final CountDownLatch l = new CountDownLatch(2); in testGetCount()
76 final CountDownLatch l = new CountDownLatch(1); in testCountDown()
88 final CountDownLatch l = new CountDownLatch(2); in testAwait()
89 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testAwait()
113 final CountDownLatch l = new CountDownLatch(2); in testTimedAwait()
114 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testTimedAwait()
138 final CountDownLatch l = new CountDownLatch(1); in testAwait_Interruptible()
139 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible()
[all …]
DScheduledExecutorTest.java47 import java.util.concurrent.CountDownLatch;
77 final CountDownLatch done = new CountDownLatch(1); in testExecute()
92 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
113 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
133 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
155 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
186 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
217 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
362 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
365 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
[all …]
DScheduledExecutorSubclassTest.java45 import java.util.concurrent.CountDownLatch;
134 final CountDownLatch done = new CountDownLatch(1); in testExecute()
146 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
169 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
189 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
211 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
242 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
273 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
418 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
421 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
[all …]
DThreadPoolExecutorTest.java47 import java.util.concurrent.CountDownLatch;
73 final CountDownLatch beforeCalled = new CountDownLatch(1);
74 final CountDownLatch afterCalled = new CountDownLatch(1);
75 final CountDownLatch terminatedCalled = new CountDownLatch(1);
118 final CountDownLatch done = new CountDownLatch(1); in testExecute()
131 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
137 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
208 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
209 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
210 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DThreadPoolExecutorSubclassTest.java46 import java.util.concurrent.CountDownLatch;
220 final CountDownLatch beforeCalled = new CountDownLatch(1);
221 final CountDownLatch afterCalled = new CountDownLatch(1);
222 final CountDownLatch terminatedCalled = new CountDownLatch(1);
265 final CountDownLatch done = new CountDownLatch(1); in testExecute()
278 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
284 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
355 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
356 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
357 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DExchangerTest.java39 import java.util.concurrent.CountDownLatch;
100 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException()
117 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException()
152 final CountDownLatch exchanged = new CountDownLatch(2); in testReplacementAfterExchange()
153 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange()
DLockSupportTest.java40 import java.util.concurrent.CountDownLatch;
141 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkBeforeUnpark()
175 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkAfterUnpark()
213 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt()
251 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt()
322 final CountDownLatch started = new CountDownLatch(1); in testGetBlocker()
DFutureTaskTest.java46 import java.util.concurrent.CountDownLatch;
439 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt()
469 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
470 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
513 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_taskFails()
542 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelNoInterrupt()
543 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelNoInterrupt()
570 final CountDownLatch pleaseRun = new CountDownLatch(2); in testGetRun()
609 final CountDownLatch pleaseSet = new CountDownLatch(2); in testGetSet()
654 final CountDownLatch pleaseCancel = new CountDownLatch(3); in testTimedGet_Cancellation()
[all …]
DLinkedBlockingDequeTest.java46 import java.util.concurrent.CountDownLatch;
611 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
648 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
649 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
681 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
717 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
789 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
841 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPutFirst()
878 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutFirstWithTake()
879 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutFirstWithTake()
[all …]
DPhaserTest.java40 import java.util.concurrent.CountDownLatch;
486 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
540 final CountDownLatch pleaseArrive = new CountDownLatch(1);
569 final CountDownLatch pleaseArrive = new CountDownLatch(1);
598 final CountDownLatch pleaseArrive = new CountDownLatch(1);
624 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
677 final CountDownLatch latch = new CountDownLatch(1);
750 final CountDownLatch pleaseForceTermination = new CountDownLatch(2);
794 final CountDownLatch pleaseArrive = new CountDownLatch(THREADS);
/libcore/luni/src/test/java/libcore/java/net/
DServerSocketConcurrentCloseTest.java30 import java.util.concurrent.CountDownLatch;
64 final CountDownLatch threadFinishedLatch = new CountDownLatch(1); in testImplAccept_detectsClosedState()
189 private final CountDownLatch startLatch = new CountDownLatch(1);
224 private final CountDownLatch startLatch = new CountDownLatch(1);
225 private final CountDownLatch shutdownLatch = new CountDownLatch(1);
DSocketTimeoutTest.java30 import java.util.concurrent.CountDownLatch;
120 CountDownLatch threadStarted = new CountDownLatch(1); in testSocketWriteNeverTimeouts()
121 CountDownLatch writeCompleted = new CountDownLatch(1); in testSocketWriteNeverTimeouts()
/libcore/luni/src/test/java/libcore/java/lang/
DOldAndroidMonitorTest.java21 import java.util.concurrent.CountDownLatch;
112 private final CountDownLatch cdl;
115 public Waiter(Object lock, CountDownLatch cdl) { in Waiter()
144 final CountDownLatch cdl = new CountDownLatch(1); in testInterrupt()
/libcore/luni/src/test/java/libcore/java/lang/ref/
DFinalizeTest.java19 import java.util.concurrent.CountDownLatch;
112 CountDownLatch latch = new CountDownLatch(3); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
120 public void createSlowFinalizer(final long millis, final CountDownLatch latch) { in createSlowFinalizer()

1234