| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionListTest.java | 41 CountDownLatch countDownLatch = new CountDownLatch(3); in testRunOnPopulatedList() local
42 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
43 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
44 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
45 assertEquals(3L, countDownLatch.getCount()); in testRunOnPopulatedList()
50 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testRunOnPopulatedList()
109 CountDownLatch countDownLatch = new CountDownLatch(1); in testAddAfterRun() local
110 list.add(new MockRunnable(countDownLatch), Executors.newCachedThreadPool()); in testAddAfterRun()
111 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testAddAfterRun()
132 CountDownLatch countDownLatch; field in ExecutionListTest.MockRunnable
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionListTest.java | 41 CountDownLatch countDownLatch = new CountDownLatch(3); in testRunOnPopulatedList() local
42 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
43 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
44 list.add(new MockRunnable(countDownLatch), exec); in testRunOnPopulatedList()
45 assertEquals(3L, countDownLatch.getCount()); in testRunOnPopulatedList()
50 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testRunOnPopulatedList()
109 CountDownLatch countDownLatch = new CountDownLatch(1); in testAddAfterRun() local
110 list.add(new MockRunnable(countDownLatch), Executors.newCachedThreadPool()); in testAddAfterRun()
111 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); in testAddAfterRun()
132 CountDownLatch countDownLatch; field in ExecutionListTest.MockRunnable
[all …]
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | MockFutureListener.java | 38 private final CountDownLatch countDownLatch; field in MockFutureListener
42 this.countDownLatch = new CountDownLatch(1); in MockFutureListener()
50 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/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | MockFutureListener.java | 38 private final CountDownLatch countDownLatch; field in MockFutureListener
42 this.countDownLatch = new CountDownLatch(1); in MockFutureListener()
50 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 | 180 CountDownLatch countDownLatch = getAndClearConnectedCondition(); in swapServiceContextAndNotify() local
181 if (countDownLatch != null) { in swapServiceContextAndNotify()
182 countDownLatch.countDown(); in swapServiceContextAndNotify()
195 CountDownLatch countDownLatch; in getConnectedCondition() local
198 countDownLatch = connectedConditionRef.get(); in getConnectedCondition()
199 if (countDownLatch != null) { in getConnectedCondition()
200 return countDownLatch; in getConnectedCondition()
202 countDownLatch = createCountDownLatch(); in getConnectedCondition()
203 } while (!connectedConditionRef.compareAndSet(/* expect= */ null, countDownLatch)); in getConnectedCondition()
204 return countDownLatch; in getConnectedCondition()
|
| /external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/testapp/ |
| D | SimpleFuture.java | 29 private final CountDownLatch countDownLatch = new CountDownLatch(1); field in SimpleFuture
35 countDownLatch.countDown(); in set()
43 countDownLatch.countDown(); in setException()
51 countDownLatch.await(); in get()
|
| /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/exoplayer/tree/extensions/cronet/src/test/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceTest.java | 1428 private void assertNotCountedDown(CountDownLatch countDownLatch) throws InterruptedException { in assertNotCountedDown() argument
1432 assertThat(countDownLatch.getCount()).isGreaterThan(0L); in assertNotCountedDown()
|
| /external/guice/lib/build/ |
| D | guava-testlib-19.0.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/google/
com/ ... |