Home
last modified time | relevance | path

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

12

/libcore/jsr166-tests/src/test/java/jsr166/
DCountDownLatchTest.java13 import java.util.concurrent.CountDownLatch;
23 new CountDownLatch(-1); in testConstructor()
32 final CountDownLatch l = new CountDownLatch(2); in testGetCount()
42 final CountDownLatch l = new CountDownLatch(1); in testCountDown()
54 final CountDownLatch l = new CountDownLatch(2); in testAwait()
55 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testAwait()
79 final CountDownLatch l = new CountDownLatch(2); in testTimedAwait()
80 final CountDownLatch pleaseCountDown = new CountDownLatch(1); in testTimedAwait()
104 final CountDownLatch l = new CountDownLatch(1); in testAwait_Interruptible()
105 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testAwait_Interruptible()
[all …]
DThreadPoolExecutorTest.java20 final CountDownLatch beforeCalled = new CountDownLatch(1);
21 final CountDownLatch afterCalled = new CountDownLatch(1);
22 final CountDownLatch terminatedCalled = new CountDownLatch(1);
64 final CountDownLatch done = new CountDownLatch(1); in testExecute()
86 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
87 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
147 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
148 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
149 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
300 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize()
[all …]
DScheduledExecutorTest.java24 final CountDownLatch done = new CountDownLatch(1); in testExecute()
43 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
66 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
88 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
112 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
283 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
284 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
307 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
308 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
309 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DExchangerTest.java13 import java.util.concurrent.CountDownLatch;
65 final CountDownLatch threadStarted = new CountDownLatch(1); in testExchange_InterruptedException()
82 final CountDownLatch threadStarted = new CountDownLatch(1); in testTimedExchange_InterruptedException()
117 final CountDownLatch exchanged = new CountDownLatch(2); in testReplacementAfterExchange()
118 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange()
DScheduledExecutorSubclassTest.java76 final CountDownLatch done = new CountDownLatch(1); in testExecute()
95 final CountDownLatch done = new CountDownLatch(1); in testSchedule1()
118 final CountDownLatch done = new CountDownLatch(1); in testSchedule3()
140 final CountDownLatch done = new CountDownLatch(1); in testSchedule4()
164 final CountDownLatch done = new CountDownLatch(1); in testSchedule5()
333 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
334 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
357 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
358 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
359 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
[all …]
DThreadPoolExecutorSubclassTest.java160 final CountDownLatch beforeCalled = new CountDownLatch(1);
161 final CountDownLatch afterCalled = new CountDownLatch(1);
162 final CountDownLatch terminatedCalled = new CountDownLatch(1);
204 final CountDownLatch done = new CountDownLatch(1); in testExecute()
226 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetActiveCount()
227 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount()
281 final CountDownLatch threadStarted = new CountDownLatch(1); in testGetCompletedTaskCount()
282 final CountDownLatch threadProceed = new CountDownLatch(1); in testGetCompletedTaskCount()
283 final CountDownLatch threadDone = new CountDownLatch(1); in testGetCompletedTaskCount()
407 final CountDownLatch threadsStarted = new CountDownLatch(THREADS); in testGetLargestPoolSize()
[all …]
DLockSupportTest.java13 import java.util.concurrent.CountDownLatch;
99 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkBeforeUnpark()
133 final CountDownLatch pleaseUnpark = new CountDownLatch(1); in testParkAfterUnpark()
171 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkBeforeInterrupt()
209 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testParkAfterInterrupt()
280 final CountDownLatch started = new CountDownLatch(1); in testGetBlocker()
DFutureTaskTest.java14 import java.util.concurrent.CountDownLatch;
398 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt()
428 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
429 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException()
472 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelInterrupt_taskFails()
501 final CountDownLatch pleaseCancel = new CountDownLatch(1); in testCancelNoInterrupt()
502 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelNoInterrupt()
529 final CountDownLatch pleaseRun = new CountDownLatch(2); in testGetRun()
568 final CountDownLatch pleaseSet = new CountDownLatch(2); in testGetSet()
613 final CountDownLatch pleaseCancel = new CountDownLatch(3); in testTimedGet_Cancellation()
[all …]
DLinkedBlockingDequeTest.java18 import java.util.concurrent.CountDownLatch;
550 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
587 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
588 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
620 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
656 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
728 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
782 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPutFirst()
819 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutFirstWithTake()
820 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutFirstWithTake()
[all …]
DPhaserTest.java14 import java.util.concurrent.CountDownLatch;
451 final CountDownLatch pleaseInterrupt = new CountDownLatch(2);
505 final CountDownLatch pleaseArrive = new CountDownLatch(1);
534 final CountDownLatch pleaseArrive = new CountDownLatch(1);
563 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
589 final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
642 final CountDownLatch latch = new CountDownLatch(1);
715 final CountDownLatch pleaseForceTermination = new CountDownLatch(2);
759 final CountDownLatch pleaseArrive = new CountDownLatch(THREADS);
DExecutorsTest.java176 final CountDownLatch proceed = new CountDownLatch(1); in testNewSingleThreadScheduledExecutor()
202 final CountDownLatch proceed = new CountDownLatch(1); in testNewScheduledThreadPool()
230 final CountDownLatch proceed = new CountDownLatch(1); in testUnconfigurableScheduledExecutorService()
287 final CountDownLatch done = new CountDownLatch(1); in testDefaultThreadFactory()
326 final CountDownLatch done = new CountDownLatch(1); in testPrivilegedThreadFactory()
DSynchronousQueueTest.java19 import java.util.concurrent.CountDownLatch;
101 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
133 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
134 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
167 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
228 final CountDownLatch pleaseOffer = new CountDownLatch(1); in testTimedPollWithOffer()
229 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedPollWithOffer()
DReentrantLockTest.java14 import java.util.concurrent.CountDownLatch;
582 final CountDownLatch locked = new CountDownLatch(1); in testAwait()
735 final CountDownLatch pleaseSignal = new CountDownLatch(1); in testHasWaiters()
768 final CountDownLatch locked1 = new CountDownLatch(1); in testGetWaitQueueLength()
769 final CountDownLatch locked2 = new CountDownLatch(1); in testGetWaitQueueLength()
826 final CountDownLatch locked1 = new CountDownLatch(1); in testGetWaitingThreads()
827 final CountDownLatch locked2 = new CountDownLatch(1); in testGetWaitingThreads()
886 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly()
940 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testInterruptible()
978 final CountDownLatch pleaseSignal = new CountDownLatch(2); in testSignalAll()
[all …]
DCyclicBarrierTest.java14 import java.util.concurrent.CountDownLatch;
120 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait1_Interrupted_BrokenBarrier()
146 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwait2_Interrupted_BrokenBarrier()
246 final CountDownLatch pleaseReset = new CountDownLatch(2); in testReset_BrokenBarrier()
DForkJoinPoolTest.java16 import java.util.concurrent.CountDownLatch;
258 final CountDownLatch uehInvoked = new CountDownLatch(1); in testSetUncaughtExceptionHandler()
370 final CountDownLatch done = new CountDownLatch(1); in testPollSubmission()
389 final CountDownLatch done = new CountDownLatch(1); in testDrainTasksTo()
576 final CountDownLatch submitted = new CountDownLatch(1); in testInterruptedSubmit()
577 final CountDownLatch quittingTime = new CountDownLatch(1); in testInterruptedSubmit()
667 CountDownLatch latch = new CountDownLatch(1); in testInvokeAny4()
847 CountDownLatch latch = new CountDownLatch(1); in testTimedInvokeAny3()
DLinkedBlockingQueueTest.java19 import java.util.concurrent.CountDownLatch;
240 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
277 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
278 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
310 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
346 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
418 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
DBlockingQueueTest.java18 import java.util.concurrent.CountDownLatch;
248 final CountDownLatch threadStarted = new CountDownLatch(1);
289 final CountDownLatch threadStarted = new CountDownLatch(1);
DArrayBlockingQueueTest.java20 import java.util.concurrent.CountDownLatch;
250 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingPut()
287 final CountDownLatch pleaseTake = new CountDownLatch(1); in testPutWithTake()
288 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testPutWithTake()
320 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedOffer()
356 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
429 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
DTimeUnitTest.java12 import java.util.concurrent.CountDownLatch;
354 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedWait_Interruptible()
389 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedJoin_Interruptible()
424 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTimedSleep_Interruptible()
DReentrantReadWriteLockTest.java16 import java.util.concurrent.CountDownLatch;
984 final CountDownLatch locked = new CountDownLatch(1); in testAwait()
1011 final CountDownLatch pleaseInterrupt = new CountDownLatch(2); in testAwaitUninterruptibly()
1065 final CountDownLatch locked = new CountDownLatch(1); in testInterruptible()
1104 final CountDownLatch locked = new CountDownLatch(2); in testSignalAll()
1137 final CountDownLatch locked1 = new CountDownLatch(1); in testSignalWakesFifo()
1138 final CountDownLatch locked2 = new CountDownLatch(1); in testSignalWakesFifo()
1185 final CountDownLatch locked = new CountDownLatch(2); in testAwaitLockCount()
1516 final CountDownLatch locked = new CountDownLatch(1); in testHasWaiters()
1550 final CountDownLatch locked = new CountDownLatch(1); in testGetWaitQueueLength()
[all …]
DLinkedTransferQueueTest.java19 import java.util.concurrent.CountDownLatch;
192 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testBlockingTake()
266 final CountDownLatch aboutToWait = new CountDownLatch(1); in testInterruptedTimedPoll()
703 final CountDownLatch threadStarted = new CountDownLatch(1); in testWaitingConsumer()
743 final CountDownLatch threadStarted = new CountDownLatch(1); in testTransfer2()
910 final CountDownLatch pleaseInterrupt = new CountDownLatch(1); in testTryTransfer5()
/libcore/luni/src/test/java/libcore/java/lang/ref/
DFinalizeTest.java19 import java.util.concurrent.CountDownLatch;
100 CountDownLatch latch = new CountDownLatch(5); in testWatchdogDoesNotFailForObjectsThatAreNearTheDeadline()
110 public void createSlowFinalizer(final long millis, final CountDownLatch latch) { in createSlowFinalizer()
/libcore/luni/src/main/java/java/util/concurrent/
DCountDownLatch.java127 public class CountDownLatch { class
169 public CountDownLatch(int count) { in CountDownLatch() method in CountDownLatch
/libcore/luni/src/test/java/libcore/java/nio/channels/
DSelectorTest.java28 import java.util.concurrent.CountDownLatch;
118 final CountDownLatch selectReturned = new CountDownLatch(1); in testManyWakeupCallsTriggerOnlyOneWakeup()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java28 import java.util.concurrent.CountDownLatch;
252 final CountDownLatch latch = new CountDownLatch(THREAD_COUNT); in testMessageDigest_MultipleThreads_Misuse()

12