Searched refs:Future (Results 1 - 25 of 109) sorted by relevance

12345

/external/chromium_org/chrome/common/extensions/docs/server2/
H A Doffline_file_system.py6 from future import Future namespace
17 if skip_not_found: return Future(value={})
20 return Future(callback=raise_file_not_found)
H A Dfuture_test.py10 from future import All, Future, Race namespace
16 self.assertRaises(ValueError, Future)
19 future = Future(value=42)
29 future = Future(callback=callback)
65 future = Future(callback=callback)
75 future = All((Future(callback=callback),))
84 future = All(Future(callback=callback) for callback in callbacks)
98 future = All(Future(callback=callback) for callback in callbacks)
108 future = All((Future(callback=callback) for callback in callbacks),
118 race = Race((Future(callbac
[all...]
H A Dempty_dir_file_system.py6 from future import Future namespace
21 return Future(value=result)
24 return Future(value=())
H A Dfuture.py17 '''Creates a Future which returns a list of results from each Future in
20 If any Future raises an error other than those in |except_pass| the returned
21 Future will raise as well.
23 If any Future raises an error in |except_pass| then None will be inserted as
38 return Future(callback=resolve)
42 '''Returns a Future which resolves to the first Future in |futures| that
64 return Future(callback=resolve)
67 class Future(objec class in inherits:object
[all...]
H A Dtest_patcher.py5 from future import Future namespace
29 return Future(value=dict((path, self._patch_data[path])
H A Dcompiled_file_system.py9 from future import Future namespace
160 return Future(value=None)
167 '''Returns a Future containing the recursive directory listing of |path| as
183 # asynchronous Future contract) because there's a greater chance to
189 return Future(exc_info=sys.exc_info())
192 return Future(value=first_layer_files)
229 return Future(exc_info=sys.exc_info())
233 return Future(value=cache_entry.cache_data)
252 return Future(exc_info=sys.exc_info())
256 return Future(valu
[all...]
H A Dplatform_bundle.py15 from future import Future namespace
89 Future(callback=lambda: self.GetReferenceResolver(platform)),
90 Future(callback=lambda: self.GetAPIModels(platform)),
91 Future(callback=lambda: self.GetFeaturesBundle(platform)),
114 Future(callback=lambda: self.GetReferenceResolver(platform)),
115 Future(callback=lambda: self.GetAPIModels(platform)),
116 Future(callback=lambda: self.GetFeaturesBundle(platform)),
H A Dcache_chain_object_store.py5 from future import Future namespace
43 return Future(value=cached_items)
50 # Don't realise the Future value of an object store that we don't need to;
75 return Future(callback=resolve)
H A Dpermissions_data_source.py10 from future import Future namespace
74 return Future(callback=resolve)
84 return Future(callback=resolve)
H A Dlocal_file_system.py10 from future import Future namespace
96 return Future(exc_info=sys.exc_info())
98 return Future(callback=resolve)
101 return Future(value=())
H A Dobject_store.py5 from future import Future namespace
12 '''Gets a |Future| with the value of |key| in the object store, or None
18 '''Gets a |Future| with values mapped to |keys| from the object store, with
/external/guava/guava/src/com/google/common/util/concurrent/
H A DListenableFuture.java21 import java.util.concurrent.Future;
26 * A {@link Future} that accepts completion listeners. Each listener has an
28 * computation is {@linkplain Future#isDone() complete}. If the computation has
35 * derived {@code Future}, as in {@link Futures#allAsList(Iterable)
41 * access to the {@code Future} result. (Users who want such access may prefer
61 * depends on how they currently create {@code Future} instances:
73 * Occasionally, an API will return a plain {@code Future} and it will be
82 public interface ListenableFuture<V> extends Future<V> {
85 * the given executor. The listener will run when the {@code Future}'s
86 * computation is {@linkplain Future#isDon
[all...]
H A DForwardingFuture.java23 import java.util.concurrent.Future;
28 * A {@link Future} which forwards all its method calls to another future.
39 implements Future<V> {
44 @Override protected abstract Future<V> delegate();
78 * can pass in an already constructed {@link Future} as the delegate.
84 private final Future<V> delegate;
86 protected SimpleForwardingFuture(Future<V> delegate) {
91 protected final Future<V> delegate() {
H A DListeningExecutorService.java23 import java.util.concurrent.Future;
69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
85 <T> List<Future<T>> invokeAll(
H A DAbstractListeningExecutorService.java27 import java.util.concurrent.Future;
67 List<Future<T>> futures = new ArrayList<Future<T>>(ntasks);
89 Future<T> f = ecs.poll();
126 for (Future<T> f : futures) {
147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size());
160 for (Future<T> f : futures) {
173 for (Future<
[all...]
H A DAsyncFunction.java21 import java.util.concurrent.Future;
33 * Returns an output {@code Future} to use in place of the given {@code
34 * input}. The output {@code Future} need not be {@linkplain Future#isDone
38 * failing {@code Future}.
H A DFutureCallback.java22 import java.util.concurrent.Future;
25 * A callback for accepting the results of a {@link java.util.concurrent.Future}
36 * Invoked with the result of the {@code Future} computation when it is
42 * Invoked when a {@code Future} computation fails or is canceled.
44 * <p>If the future's {@link Future#get() get} method throws an {@link
H A DJdkFutureAdapters.java26 import java.util.concurrent.Future;
32 * Future} instances. Note that, whenver possible, it is strongly preferred to
42 * Assigns a thread to the given {@link Future} to provide {@link
49 * until the future is {@linkplain Future#isDone() done}.
55 * Future} instances to be upgraded to {@code ListenableFuture} after the
59 Future<V> future) {
68 Future<V> future, Executor executor) {
77 * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This
107 private final Future<V> delegate;
109 ListenableFutureAdapter(Future<
[all...]
H A DForwardingExecutorService.java26 import java.util.concurrent.Future;
54 public <T> List<Future<T>> invokeAll(
60 public <T> List<Future<T>> invokeAll(
104 public <T> Future<T> submit(Callable<T> task) {
109 public Future<?> submit(Runnable task) {
114 public <T> Future<T> submit(Runnable task, T result) {
/external/guava/guava-bootstrap/src/java/util/concurrent/
H A DExecutorService.java28 <T> Future<T> submit(Callable<T> task);
30 <T> Future<T> submit(Runnable task, T result);
32 Future<?> submit(Runnable task);
34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
37 <T> List<Future<T>> invokeAll(
/external/clang/test/SemaCXX/
H A Ddecltype.cpp20 struct Future { struct
21 explicit Future(T v);
36 Future<int> f1(42);
37 f1.call([](int){ return Future<float>(0); });
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/
H A DRobolectricBackgroundExecutorService.java10 import java.util.concurrent.Future;
42 public <T> Future<T> submit(Callable<T> tCallable) {
47 public <T> Future<T> submit(Runnable runnable, T t) {
52 public Future<?> submit(Runnable runnable) {
56 private <T> Future<T> schedule(final FutureTask<T> futureTask) {
68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException {
73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
/external/junit/src/org/junit/experimental/
H A DParallelComputer.java8 import java.util.concurrent.Future;
38 private final List<Future<Object>> fResults= new ArrayList<Future<Object>>();
53 for (Future<Object> each : fResults)
/external/robolectric/src/test/java/com/xtremelabs/robolectric/util/
H A DRobolectricBackgroundExecutorServiceTest.java10 import java.util.concurrent.Future;
47 Future<String> future = executorService.submit(runnable, "foo");
61 Future<String> future = executorService.submit(new Callable<String>() {
/external/chromium_org/components/devtools_bridge/android/javatests/src/org/chromium/components/devtools_bridge/
H A DLocalTunnelBridgeTest.java15 import java.util.concurrent.Future;
68 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST);
86 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST);
104 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST);

Completed in 3880 milliseconds

12345