| /external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/ |
| D | ConcurrentWeakIdentityHashMapTest.java | 51 testConcurrentWeakIdentityHashMapSingleThreadedHelper(CountDownLatch latch) in testConcurrentWeakIdentityHashMapSingleThreadedHelper()
86 CountDownLatch latch = new CountDownLatch(5); in testSingleThreadedUse() local
99 int numMainExceptions, int numSuppressedPerMain, CountDownLatch latch) { in createExceptionWithSuppressed()
115 int numMainExceptions, int numSuppressedPerMain, CountDownLatch latch) in testFunctionalCorrectnessForMultiThreadedUse()
162 CountDownLatch latch = new CountDownLatch(numMainExceptions * numSuppressedPerMain); in testMultiThreadedUse() local
201 private final CountDownLatch latch; field in ConcurrentWeakIdentityHashMapTest.ExceptionWithLatch
203 private ExceptionWithLatch(String message, CountDownLatch latch) { in ExceptionWithLatch()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 21 val latch = CountDownLatch(1) in <lambda>() constant
34 val latch = CountDownLatch(taskModes.size) in <lambda>() constant
125 val latch = CountDownLatch(1) in <lambda>() constant
136 var latch = CountDownLatch(1) in <lambda>() variable
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/flow/ |
| D | FlowCancellationTest.kt | 16 val latch = Channel<Unit>(1) in <lambda>() constant
33 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | FlatMapMergeBaseTest.kt | 37 val latch = Channel<Unit>() in testConcurrentFailure() constant
67 val latch = Channel<Unit>() in <lambda>() constant
|
| D | FilterTest.kt | 29 val latch = Channel<Unit>() in <lambda>() constant
64 val latch = Channel<Unit>() in <lambda>() constant
|
| D | MapNotNullTest.kt | 33 val latch = Channel<Unit>() in <lambda>() constant
|
| D | OnEachTest.kt | 33 val latch = Channel<Unit>() in <lambda>() constant
|
| D | MapTest.kt | 32 val latch = Channel<Unit>() in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/ |
| D | FirstTest.kt | 37 val latch = Channel<Unit>() in <lambda>() constant
66 val latch = Channel<Unit>() in <lambda>() constant
104 val latch = Channel<Unit>() in <lambda>() constant
139 val latch = Channel<Unit>() in <lambda>() constant
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 115 final CountDownLatch latch = new CountDownLatch(1); in futureCallCallback() local
144 final CountDownLatch latch = new CountDownLatch(1); in asyncCall() local
182 final CountDownLatch latch = new CountDownLatch(1); in advancedAsyncCall() local
|
| D | DetailErrorSample.java | 142 final CountDownLatch latch = new CountDownLatch(1); in futureCallCallback() local
168 final CountDownLatch latch = new CountDownLatch(1); in asyncCall() local
203 final CountDownLatch latch = new CountDownLatch(1); in advancedAsyncCall() local
|
| /external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 71 final CountDownLatch latch = new CountDownLatch(1); in runTest() local
132 final CountDownLatch latch = new CountDownLatch(1); in getTestCount() local
171 final CountDownLatch latch = new CountDownLatch(1); in updateReports() local
|
| /external/apache-commons-lang/src/test/java/org/apache/commons/lang3/concurrent/ |
| D | TimedSemaphoreTest.java | 215 final CountDownLatch latch = new CountDownLatch(count - 1); in testAcquireLimit() local
289 final CountDownLatch latch = new CountDownLatch(count); in testAcquireNoLimit() local
320 final CountDownLatch latch = new CountDownLatch(count); in testAcquireMultiplePeriods() local
384 final CountDownLatch latch = new CountDownLatch(1); in testTryAcquire() local
420 volatile CountDownLatch latch; field in TimedSemaphoreTest.TimedSemaphoreTestImpl
487 private final CountDownLatch latch; field in TimedSemaphoreTest.SemaphoreThread
532 private final CountDownLatch latch; field in TimedSemaphoreTest.TryAcquireThread
|
| /external/dagger2/javatests/artifacts/hilt-android/simple/app/src/androidTest-agp-4.2.0/java/dagger/hilt/android/simple/ |
| D | BroadcastReceiverTest.java | 116 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverOne
131 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverTwo
146 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverThree
162 final CountDownLatch latch = new CountDownLatch(1); field in BroadcastReceiverTest.TestReceiverFour
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | IterableFlowTckTest.kt | 48 val latch = CountDownLatch(1) in testStackOverflowTrampoline() constant
83 val latch = CountDownLatch(1) in testConcurrentRequest() constant
|
| /external/dagger2/javatests/dagger/internal/ |
| D | DoubleCheckTest.java | 80 final CountDownLatch latch = new CountDownLatch(numThreads); in get() local
105 final CountDownLatch latch; field in DoubleCheckTest.LatchedProvider
107 LatchedProvider(CountDownLatch latch) { in LatchedProvider()
|
| /external/robolectric/integration_tests/nativegraphics/src/test/java/org/robolectric/integrationtests/nativegraphics/testing/util/ |
| D | WebViewReadyHelper.java | 15 private final CountDownLatch latch; field in WebViewReadyHelper
18 public WebViewReadyHelper(WebView webView, CountDownLatch latch) { in WebViewReadyHelper()
|
| /external/tensorflow/tensorflow/core/tfrt/runtime/ |
| D | tf_threadpool_concurrent_work_queue_test.cc | 68 tfrt::latch latch(10); in TEST_F() local
86 tfrt::latch latch(10); in TEST_F() local
103 tfrt::latch latch(20); in TEST_F() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSourceAsFlowStressTest.kt | 26 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowPausedSystemClockTest.java | 52 CountDownLatch latch = new CountDownLatch(2); in sleep_concurrentAccess() local
95 CountDownLatch latch = new CountDownLatch(2); in setCurrentTimeMillis_concurrentAccess() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ReusableCancellableContinuationInvariantStressTest.kt | 29 val latch = CountDownLatch(1) in doTest() constant
|
| D | RunInterruptibleTest.kt | 40 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableSourceAsFlowStressTest.kt | 27 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 195 public static void await(CountDownLatch latch) { in await()
223 private static void createUnreachableLatchFinalizer(CountDownLatch latch) { in createUnreachableLatchFinalizer()
|
| /external/guava/android/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 195 public static void await(CountDownLatch latch) { in await()
223 private static void createUnreachableLatchFinalizer(CountDownLatch latch) { in createUnreachableLatchFinalizer()
|