HomeSort by relevance Sort by last modified time
    Searched refs:futures (Results 1 - 25 of 28) sorted by null

1 2

  /external/chromium_org/chrome/common/extensions/docs/server2/
persistent_object_store.py 30 futures = []
32 futures.append(db.put_async(
34 # If running the dev server, the futures don't complete until the server is
37 [future.wait() for future in futures]
43 futures = []
45 futures.append(db.delete_async(
47 # If running the dev server, the futures don't complete until the server is
50 [future.wait() for future in futures]
redirector.py 64 futures = []
67 futures.append(
69 return Future(delegate=Gettable(lambda: [f.Get() for f in futures]))
api_models.py 65 futures = [self._model_cache.GetFromFile('%s/%s.%s' % (API, file_name, ext))
68 for future in futures:
73 futures[0].Get()
sidenav_data_source.py 81 futures = [self._cache.GetFromFile('%s/%s_sidenav.json' %
84 return Future(delegate=Gettable(lambda: [f.Get() for f in futures]))
caching_file_system_test.py 117 futures = (file_system.ReadSingle('bob/bob1'),
121 tuple(future.Get() for future in futures))
131 futures = (file_system.ReadSingle('bob/bob1'),
137 tuple(future.Get() for future in futures))
compiled_file_system.py 179 def get_from_future_listing(futures):
180 '''Recursively lists files from directory listing |futures|.
183 for dir_name, listing in futures.Get().iteritems():
  /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/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/
JsDocValidator.java 38 List<Future<ValidatorContext>> futures = new ArrayList<>(args.length); local
40 futures.add(executor.submit(new FileCheckerCallable(fileName)));
44 for (Future<ValidatorContext> future : futures) {
  /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 

Completed in 919 milliseconds

1 2