| /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/jvm/test/flow/ |
| D | FlowCancellationTest.kt | 15 val latch = Channel<Unit>(1) in <lambda>() constant
32 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
65 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
|
| D | FoldTest.kt | 31 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/dagger2/java/dagger/hilt/android/example/gradle/simple/app/src/sharedTest/java/dagger/hilt/android/example/gradle/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/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/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | IterableFlowTckTest.kt | 54 val latch = CountDownLatch(1) in testStackOverflowTrampoline() constant
89 val latch = CountDownLatch(1) in testConcurrentRequest() constant
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/ |
| D | ListenableFutureTest.kt | 205 val latch = CountDownLatch(1) in <lambda>() constant
227 val latch = CountDownLatch(1) in <lambda>() constant
248 val latch = CountDownLatch(1) in <lambda>() constant
271 val latch = CountDownLatch(1) in <lambda>() constant
295 val latch = CountDownLatch(1) in <lambda>() constant
442 val latch = CountDownLatch(1) in <lambda>() constant
550 val latch = CountDownLatch(1) in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSourceAsFlowStressTest.kt | 26 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/android/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 197 public static void await(CountDownLatch latch) { in await()
225 private static void createUnreachableLatchFinalizer(final CountDownLatch latch) { in createUnreachableLatchFinalizer()
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| D | GcFinalization.java | 197 public static void await(CountDownLatch latch) { in await()
225 private static void createUnreachableLatchFinalizer(final CountDownLatch latch) { in createUnreachableLatchFinalizer()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | RunInterruptibleTest.kt | 40 val latch = Channel<Unit>(1) in <lambda>() constant
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 43 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch() local
146 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch_Interrupted() local
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 43 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch() local
148 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch_Interrupted() local
|
| /external/llvm-project/libcxx/test/libcxx/thread/ |
| D | latch.availability.verify.cpp | 25 std::latch latch(10); in main() local
|