| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| offline_file_system.py | 6 from future import Future
17 if skip_not_found: return Future(value={})
20 return Future(callback=raise_file_not_found)
|
| future_test.py | 10 from future import All, Future, Race
16 self.assertRaises(ValueError, Future)
19 future = Future(value=42)
20 self.assertEqual(42, future.Get())
21 self.assertEqual(42, future.Get())
29 future = Future(callback=callback)
30 self.assertEqual(42, future.Get()
[all...] |
| empty_dir_file_system.py | 6 from future import Future
21 return Future(value=result)
24 return Future(value=())
|
| test_patcher.py | 5 from future import Future
29 return Future(value=dict((path, self._patch_data[path])
|
| future.py | 17 '''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
51 for future in futures:
53 first_future = future
[all...] |
| compiled_file_system.py | 9 from future import Future
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()
[all...] |
| cache_chain_object_store.py | 5 from future import Future
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)
|
| persistent_object_store.py | 8 from future import Future
26 [future.wait() for future in futures]
34 return dict((key, future.get_result().GetValue())
35 for key, future in db_futures.iteritems()
36 if future.get_result() is not None)
37 return Future(callback=resolve)
47 [future.wait() for future in futures
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenableFuture.java | 21 import java.util.concurrent.Future;
26 * A {@link Future} that accepts completion listeners. Each listener has an
27 * associated executor, and it is invoked using this executor once the future's
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
46 * ListenableFuture<Result> future = service.query(name);
47 * future.addListener(new Runnable() {
61 * depends on how they currently create {@code Future} instances:
73 * Occasionally, an API will return a plain {@code Future} and it will b
[all...] |
| ForwardingFuture.java | 23 import java.util.concurrent.Future;
28 * A {@link Future} which forwards all its method calls to another future.
30 * the backing future as desired per the <a
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()
[all...] |
| ListeningExecutorService.java | 23 import java.util.concurrent.Future;
69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
85 <T> List<Future<T>> invokeAll(
|
| AbstractListeningExecutorService.java | 27 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<T> f : futures)
[all...] |
| AsyncFunction.java | 21 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}.
|
| FutureCallback.java | 22 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
|
| JdkFutureAdapters.java | 26 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
45 * <p><b>Warning:</b> If the input future does not already implement {@link
46 * ListenableFuture}, the returned future will emulate {@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) {
[all...] |
| ForwardingExecutorService.java | 26 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) {
|
| CheckedFuture.java | 23 import java.util.concurrent.Future;
30 * easier to create a future that executes logic which can throw an exception.
35 * {@code Future#get()}: {@link CancellationException},
40 * listeners to be added. This allows the future to be used as a normal
41 * {@link Future} or as an asynchronous callback mechanism as needed. This
43 * future will guarantee execution of all listeners when the task completes.
45 * <p>For a simpler alternative to CheckedFuture, consider accessing Future
46 * values with {@link Futures#get(Future, Class) Futures.get()}.
56 * Exception checking version of {@link Future#get()} that will translate
60 * @return the result of executing the future
[all...] |
| AbstractScheduledService.java | 25 import java.util.concurrent.Future;
120 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
139 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
147 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
158 private volatile Future<?> runningTask;
329 /** The future that represents the next execution of this task.*/
331 private Future<Void> currentFuture;
348 * Atomically reschedules this task and assigns the new future to {@link #currentFuture}.
352 // cancel calls cancel on the correct future. 2. we want to make sure that the assignment
364 // because the service does not monitor the state of the future so if the exception is no
[all...] |
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| ExecutorService.java | 28 <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/ |
| decltype.cpp | 20 struct Future {
21 explicit Future(T v);
36 Future<int> f1(42);
37 f1.call([](int){ return Future<float>(0); });
|
| /external/junit/src/org/junit/experimental/ |
| ParallelComputer.java | 8 import java.util.concurrent.Future;
38 private final List<Future<Object>> fResults= new ArrayList<Future<Object>>();
53 for (Future<Object> each : fResults)
|
| /external/chromium_org/components/devtools_bridge/android/javatests/src/org/chromium/components/devtools_bridge/ |
| LocalTunnelBridgeTest.java | 15 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);
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractListeningExecutorServiceTest.java | 29 import java.util.concurrent.Future;
61 Future<?> future = e.submit(task); local
62 future.get();
71 Future<String> future = e.submit(new StringTask()); local
72 String result = future.get();
81 Future<?> future = e.submit(new NoOpRunnable()); local
82 future.get()
91 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| /cts/tests/tests/hardware/src/android/hardware/cts/helpers/sensoroperations/ |
| ParallelSensorOperation.java | 29 import java.util.concurrent.Future;
96 ArrayList<Future<SensorOperation>> futures = new ArrayList<>();
98 Future<SensorOperation> future = executor.submit(new Callable<SensorOperation>() { local
105 futures.add(future);
118 Future<SensorOperation> future = futures.get(i); local
120 SensorOperation operation = getFutureResult(future, executionTimeNs);
131 future.cancel(true /* mayInterruptIfRunning */);
162 * Helper method that waits for a {@link Future} to complete, and returns its result
[all...] |
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/ |
| JsDocValidator.java | 16 import java.util.concurrent.Future;
31 List<Future<ValidatorContext>> futures = new ArrayList<>(args.length);
32 Map<Future<ValidatorContext>, String> fileNamesByFuture = new HashMap<>();
34 Future<ValidatorContext> future = executor.submit(new FileCheckerCallable(fileName)); local
35 fileNamesByFuture.put(future, fileName);
36 futures.add(future);
40 for (Future<ValidatorContext> future : futures) {
42 ValidatorContext context = future.get()
[all...] |
