| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AbstractListeningExecutorService.java | 67 List<Future<T>> futures = new ArrayList<Future<T>>(ntasks); local
84 futures.add(ecs.submit(it.next()));
93 futures.add(ecs.submit(it.next()));
126 for (Future<T> f : futures) {
152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
157 futures.add(f);
160 for (Future<T> f : futures) {
170 return futures;
173 for (Future<T> f : futures) {
187 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()) local
[all...] |
| Futures.java | 64 public final class Futures {
65 private Futures() {}
108 return Futures.makeChecked(future, new Function<Exception, X>() {
150 return makeChecked(Futures.<V>immediateFailedFuture(exception),
242 * fast and lightweight, consider {@linkplain Futures#chain(ListenableFuture,
367 * Futures#transform(ListenableFuture, Function) the other overload} or
476 * consider {@linkplain Futures#transform(ListenableFuture, Function) the
604 * Delegate the get() to the input and output futures, in case
639 * Delegate the get() to the input and output futures, in case
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 118 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); local
136 futures.add(ecs.submit(it.next()));
145 futures.add(ecs.submit(it.next()));
178 for (Future<T> f : futures)
203 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
208 futures.add(f);
211 for (Future<T> f : futures) {
221 return futures;
224 for (Future<T> f : futures)
235 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()) local
[all...] |
| ForkJoinPool.java | 95 * <td> {@link ForkJoinTask#fork} (ForkJoinTasks <em>are</em> Futures)</td>
1604 List<Future<T>> futures = (List<Future<T>>) (List) forkJoinTasks; local
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractListeningExecutorServiceTest.java | 379 List<Future<String>> futures = e.invokeAll(l); local
380 assertEquals(1, futures.size());
382 futures.get(0).get();
401 List<Future<String>> futures = e.invokeAll(l); local
402 assertEquals(2, futures.size());
403 for (Future<String> future : futures)
578 List<Future<String>> futures = local
580 assertEquals(1, futures.size());
582 futures.get(0).get();
601 List<Future<String>> futures local
622 List<Future<String>> futures = local
[all...] |
| MoreExecutorsTest.java | 113 List<Future<Integer>> futures = local
117 Future<Integer> future = futures.get(i);
|
| FuturesTest.java | 20 import static com.google.common.util.concurrent.Futures.allAsList;
21 import static com.google.common.util.concurrent.Futures.get;
22 import static com.google.common.util.concurrent.Futures.getUnchecked;
23 import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
24 import static com.google.common.util.concurrent.Futures.immediateFuture;
25 import static com.google.common.util.concurrent.Futures.successfulAsList;
64 * Unit tests for {@link Futures}.
66 * TODO: Add tests for other Futures methods
96 ListenableFuture<String> future = Futures.immediateFuture(DATA1);
103 ListenableFuture<String> future1 = Futures.immediateFuture(DATA1)
[all...] |
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ConcurrentHashMultisetBasherTest.java | 72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); local
74 futures.add(pool.submit(new MutateTask(multiset, keys)));
78 for (Future<int[]> future : futures) {
|
| /prebuilts/sdk/tools/lib/ |
| guava-10.0.1.jar | |
| lint.jar | |
| lint_api.jar | |
| lint_checks.jar | |
| /prebuilts/tools/common/guava-tools/ |
| guava-13.0.1.jar | |
| /prebuilts/misc/common/tradefed/ |
| tradefed-prebuilt.jar | |
