Searched refs:countDownLatch (Results 1 – 6 of 6) sorted by relevance
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionListTest.java | 43 CountDownLatch countDownLatch = new CountDownLatch(3); in testRunOnPopulatedList() local
44 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
45 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
46 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
47 assertEquals(countDownLatch.getCount(), 3L); in testRunOnPopulatedList()
52 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testRunOnPopulatedList()
103 CountDownLatch countDownLatch = new CountDownLatch(1); in testAddAfterRun() local
104 list.add(new MockRunnable(countDownLatch), Executors.newCachedThreadPool()); in testAddAfterRun()
105 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testAddAfterRun()
125 CountDownLatch countDownLatch; field in ExecutionListTest.MockRunnable
[all …]
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | MockFutureListener.java | 39 private final CountDownLatch countDownLatch; field in MockFutureListener
43 this.countDownLatch = new CountDownLatch(1); in MockFutureListener()
51 countDownLatch.countDown(); in run()
62 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertSuccess()
78 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertException()
91 Assert.assertFalse(countDownLatch.await(1L, TimeUnit.SECONDS)); in assertTimeout()
|
| /external/setupcompat/main/java/com/google/android/setupcompat/internal/ |
| D | SetupCompatServiceProvider.java | 184 CountDownLatch countDownLatch = getAndClearConnectedCondition(); in swapServiceContextAndNotify() local
185 if (countDownLatch != null) { in swapServiceContextAndNotify()
186 countDownLatch.countDown(); in swapServiceContextAndNotify()
199 CountDownLatch countDownLatch; in getConnectedCondition() local
202 countDownLatch = connectedConditionRef.get(); in getConnectedCondition()
203 if (countDownLatch != null) { in getConnectedCondition()
204 return countDownLatch; in getConnectedCondition()
206 countDownLatch = createCountDownLatch(); in getConnectedCondition()
207 } while (!connectedConditionRef.compareAndSet(/* expect= */ null, countDownLatch)); in getConnectedCondition()
208 return countDownLatch; in getConnectedCondition()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | HttpOverSpdyTest.java | 201 CountDownLatch countDownLatch = new CountDownLatch(2); in synchronousSpdyRequest() local
202 executor.execute(new SpdyRequest("/r1", countDownLatch)); in synchronousSpdyRequest()
203 executor.execute(new SpdyRequest("/r2", countDownLatch)); in synchronousSpdyRequest()
204 countDownLatch.await(); in synchronousSpdyRequest()
444 CountDownLatch countDownLatch; field in HttpOverSpdyTest.SpdyRequest
445 public SpdyRequest(String path, CountDownLatch countDownLatch) { in SpdyRequest() argument
447 this.countDownLatch = countDownLatch; in SpdyRequest()
454 countDownLatch.countDown(); in run()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerTest.java | 130 final CountDownLatch countDownLatch = new CountDownLatch(1); in childChannelOptions() local
160 countDownLatch.countDown(); in childChannelOptions()
171 countDownLatch.await(); in childChannelOptions()
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| D | VideoRendererGui.java | 498 final CountDownLatch countDownLatch = new CountDownLatch(1); in create() local
505 countDownLatch.countDown(); in create()
510 countDownLatch.await(); in create()
|