| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| persistent_object_store.py | 29 futures = []
31 futures.append(db.put_async(
33 # If running the dev server, the futures don't complete until the server is
36 [future.wait() for future in futures]
42 futures = []
44 futures.append(db.delete_async(
46 # If running the dev server, the futures don't complete until the server is
49 [future.wait() for future in futures]
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 118 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(ntasks); local
136 futures.add(ecs.submit(it.next()));
145 futures.add(ecs.submit(it.next()));
176 for (int i = 0, size = futures.size(); i < size; i++)
177 futures.get(i).cancel(true);
201 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
206 futures.add(f);
209 for (int i = 0, size = futures.size(); i < size; i++) {
210 Future<T> f = futures.get(i);
220 return futures;
234 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
[all...] |
| ForkJoinPool.java | 96 * <td> {@link ForkJoinTask#fork} (ForkJoinTasks <em>are</em> Futures)</td>
393 * efficient futures" SIGPLAN Notices, 1993
[all...] |
| /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...] |
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| FaultTolerantNegotiator.java | 85 List<Future<InputStream>> futures = new ArrayList<Future<InputStream>>(); local
89 futures.add(service.submit(new NegotiatorService(collector)));
90 futures.add(service.submit(new NegotiatorService(collector)));
93 while (stream == null && i < futures.size()) {
119 for (Future<InputStream> future : futures) {
|
| /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/python/darwin-x86/2.7.5/lib/python2.7/compiler/ |
| pycodegen.py | 213 futures = self.get_module().futures
214 for feature in futures:
1313 futures = () variable in class:ExpressionCodeGenerator
1328 futures = () variable in class:InteractiveCodeGenerator
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/compiler/ |
| pycodegen.py | 213 futures = self.get_module().futures
214 for feature in futures:
1313 futures = () variable in class:ExpressionCodeGenerator
1328 futures = () variable in class:InteractiveCodeGenerator
[all...] |
| /prebuilts/tools/common/gradle-plugins/repository/com/google/guava/guava/14.0/ |
| guava-14.0.jar | |
| /external/droiddriver/libs/ |
| guava-13.0.jar | |
| /prebuilts/devtools/tools/lib/ |
| guava-13.0.1.jar | |
| /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/tools/common/m2/repository/com/google/guava/guava/13.0.1/ |
| guava-13.0.1.jar | |
| /prebuilts/misc/common/tradefed/ |
| tradefed-prebuilt.jar | |
