Home
last modified time | relevance | path

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

1234

/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.java49 import java.util.concurrent.CountDownLatch;
79 final CountDownLatch done = new CountDownLatch(1); in testExecute()
94 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
115 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
135 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
157 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
188 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
219 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
364 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
367 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
[all …]
DScheduledExecutorSubclassTest.java47 import java.util.concurrent.CountDownLatch;
136 final CountDownLatch done = new CountDownLatch(1); in testExecute()
148 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
171 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
191 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
213 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
244 final CountDownLatch done = new CountDownLatch(cycles); in testFixedRateSequence()
275 final CountDownLatch done = new CountDownLatch(cycles); in testFixedDelaySequence()
420 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
423 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 …]
/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 …]
/libcore/ojluni/src/test/java/lang/constant/
DDynamicConstantDescTest.java35 import java.util.concurrent.CountDownLatch;
63 final CountDownLatch taskTriggerLatch = new CountDownLatch(4); in main()
90 private final CountDownLatch latch;
92 private Task(final String className, final CountDownLatch latch) { in Task()
115 private final CountDownLatch latch;
117 private InvokeOfCanonical(final CountDownLatch latch) { in InvokeOfCanonical()
/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.java31 import java.util.concurrent.CountDownLatch;
126 CountDownLatch threadStarted = new CountDownLatch(1); in testSocketWriteNeverTimeouts()
127 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/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/
DReferenceQueueTest.java25 import java.util.concurrent.CountDownLatch;
126 public final CountDownLatch inBlock = new CountDownLatch(1); in test_remove()
127 public final CountDownLatch outOfBlock = new CountDownLatch(1); in test_remove()
204 public final CountDownLatch inBlock = new CountDownLatch(1); in test_removeJ()
205 public final CountDownLatch outOfBlock = new CountDownLatch(1); in test_removeJ()
/libcore/ojluni/src/test/java/util/Timer/
DArgs.java62 TimerTask counter(final CountDownLatch latch) { in counter()
137 class OneShotLatch extends CountDownLatch {
140 class FixedDelayLatch extends CountDownLatch {
143 class FixedRateLatch extends CountDownLatch {
146 final CountDownLatch y1 = new OneShotLatch();
147 final CountDownLatch y2 = new FixedDelayLatch();
148 final CountDownLatch y3 = new FixedRateLatch();
/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