Home
last modified time | relevance | path

Searched defs:latch (Results 1 – 25 of 66) sorted by relevance

123

/external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/
DConcurrentWeakIdentityHashMapTest.java51 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/dagger2/core/src/test/java/dagger/internal/
DDoubleCheckLazyTest.java45 final CountDownLatch latch = new CountDownLatch(numThreads); in get() local
84 final CountDownLatch latch; field in DoubleCheckLazyTest.LatchedProvider
86 LatchedProvider(CountDownLatch latch) { in LatchedProvider()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/
DErrorHandlingClient.java115 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
DDetailErrorSample.java142 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/
DAutobahnTester.java71 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/guava/guava-tests/test/com/google/common/util/concurrent/
DListenerCallQueueTest.java81 final CountDownLatch latch = new CountDownLatch(1); in testAddAndExecute_multithreaded() local
103 final CountDownLatch latch = new CountDownLatch(1); in testAddAndExecute_multithreaded_withThrowingRunnable() local
DListenableFutureTester.java43 private final CountDownLatch latch; field in ListenableFutureTester
/external/guava/guava-testlib/src/com/google/common/testing/
DGcFinalization.java165 public static void await(CountDownLatch latch) { in await()
193 private static void createUnreachableLatchFinalizer(final CountDownLatch latch) { in createUnreachableLatchFinalizer()
/external/guava/guava-testlib/test/com/google/common/testing/
DGcFinalizationTest.java43 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch() local
128 final CountDownLatch latch = new CountDownLatch(1); in testAwait_CountDownLatch_Interrupted() local
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/
DCameraFacade.java161 final CountDownLatch latch = new CountDownLatch(1); in takePicture() local
192 final CountDownLatch latch = new CountDownLatch(1); in autoFocus() local
/external/guava/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java52 public static void awaitUninterruptibly(CountDownLatch latch) { in awaitUninterruptibly()
75 public static boolean awaitUninterruptibly(CountDownLatch latch, in awaitUninterruptibly()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DPing.java27 private final CountDownLatch latch = new CountDownLatch(1); field in Ping
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DPing.java25 private final CountDownLatch latch = new CountDownLatch(1); field in Ping
/external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/
DShadowHandlerThreadTest.java78 final CountDownLatch latch = new CountDownLatch(1); in shouldCallOnLooperPrepared() local
/external/droiddriver/src/io/appium/droiddriver/actions/view/
DCloseKeyboardAction.java61 final CountDownLatch latch = new CountDownLatch(1); in perform() local
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DStreamingResponseBandwidthBenchmark.java54 private CountDownLatch latch; field in StreamingResponseBandwidthBenchmark
DStreamingPingPongsPerSecondBenchmark.java53 private CountDownLatch latch; field in StreamingPingPongsPerSecondBenchmark
DFlowControlledMessagesPerSecondBenchmark.java60 private CountDownLatch latch; field in FlowControlledMessagesPerSecondBenchmark
DAbstractBenchmark.java429 final CountDownLatch latch = new CountDownLatch(callsPerChannel * channels.length); in startStreamingCalls() local
483 final CountDownLatch latch = new CountDownLatch(callsPerChannel * channels.length); in startFlowControlledStreamingCalls() local
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/
DStreamRecorder.java47 private final CountDownLatch latch; field in StreamRecorder
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DStreamRecorder.java42 private final CountDownLatch latch; field in StreamRecorder
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
DCustomDispatcherTest.java62 final CountDownLatch latch = new CountDownLatch(1); in outOfOrderResponses() local
/external/mockwebserver/src/test/java/com/google/mockwebserver/
DCustomDispatcherTest.java62 final CountDownLatch latch = new CountDownLatch(1); in testOutOfOrderResponses() local
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DAbstractListenableFutureTest.java43 protected CountDownLatch latch; field in AbstractListenableFutureTest
/external/webrtc/talk/app/webrtc/java/android/org/webrtc/
DThreadUtils.java123 public static void awaitUninterruptibly(final CountDownLatch latch) { in awaitUninterruptibly()

123