| /libcore/luni/src/main/java/java/util/concurrent/ |
| CompletionService.java | 34 * Submits a value-returning task for execution and returns a Future
39 * @return a Future representing pending completion of the task
44 Future<V> submit(Callable<V> task);
47 * Submits a Runnable task for execution and returns a Future
53 * @return a Future representing pending completion of the task,
60 Future<V> submit(Runnable task, V result);
63 * Retrieves and removes the Future representing the next
66 * @return the Future representing the next completed task
69 Future<V> take() throws InterruptedException;
72 * Retrieves and removes the Future representing the nex
[all...] |
| ScheduledFuture.java | 11 * Usually a scheduled future is the result of scheduling
16 * @param <V> The result type returned by this Future
18 public interface ScheduledFuture<V> extends Delayed, Future<V> {
|
| RunnableFuture.java | 10 * A {@link Future} that is {@link Runnable}. Successful execution of
11 * the {@code run} method causes completion of the {@code Future}
17 * @param <V> The result type returned by this Future's {@code get} method
19 public interface RunnableFuture<V> extends Runnable, Future<V> {
21 * Sets this Future to the result of its computation
|
| ExecutorCompletionService.java | 53 * List<Future<Result>> futures
54 * = new ArrayList<Future<Result>>(n);
70 * for (Future<Result> f : futures)
81 private final BlockingQueue<Future<V>> completionQueue;
92 private final Future<V> task;
123 this.completionQueue = new LinkedBlockingQueue<Future<V>>();
140 BlockingQueue<Future<V>> completionQueue) {
149 public Future<V> submit(Callable<V> task) {
156 public Future<V> submit(Runnable task, V result) {
163 public Future<V> take() throws InterruptedException
[all...] |
| ExecutorService.java | 17 * methods that can produce a {@link Future} for tracking progress of
32 * Executor#execute} by creating and returning a {@link Future} that
107 * result is retrieved via {@code Future.get()}.
175 * Future representing the pending results of the task. The
176 * Future's {@code get} method will return the task's result upon
190 * @return a Future representing pending completion of the task
195 <T> Future<T> submit(Callable<T> task);
198 * Submits a Runnable task for execution and returns a Future
199 * representing that task. The Future's {@code get} method will
204 * @return a Future representing pending completion of the tas
[all...] |
| Future.java | 10 * A {@code Future} represents the result of an asynchronous
19 * If you would like to use a {@code Future} for the sake
21 * declare types of the form {@code Future<?>} and
34 * Future<String> future
41 * displayText(future.get()); // use future
46 * The {@link FutureTask} class is an implementation of {@code Future} that
50 * FutureTask<String> future =
55 * executor.execute(future);}</pre
[all...] |
| AbstractExecutorService.java | 49 * @param value the default value for the returned future
51 * underlying runnable and which, as a {@code Future}, will yield
65 * underlying callable and which, as a {@code Future}, will yield
78 public Future<?> submit(Runnable task) {
89 public <T> Future<T> submit(Runnable task, T result) {
100 public <T> Future<T> submit(Callable<T> task) {
118 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(ntasks);
141 Future<T> f = ecs.poll();
197 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks
[all...] |
| /frameworks/base/libs/hwui/thread/ |
| Future.h | 28 class Future: public LightRefBase<Future<T> > {
30 Future(Condition::WakeUpType type = Condition::WAKE_UP_ONE): mBarrier(type), mResult() { }
31 ~Future() { }
34 * Returns the result of this future, blocking if
|
| Task.h | 25 #include "Future.h"
39 Task(): mFuture(new Future<T>()) { }
52 const sp<Future<T> >& future() const { function in class:android::uirenderer::Task
57 sp<Future<T> > mFuture;
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| FutureListener.java | 20 public void onFutureDone(Future<T> future);
|
| Future.java | 19 // This Future differs from the java.util.concurrent.Future in these aspects:
23 // ignore that flag. Regardless whether the Future is cancelled, a return
25 // null if it finds the Future is cancelled.
29 public interface Future<T> {
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| empty_dir_file_system.py | 6 from future import Future
18 return Future(value=result)
21 return Future(value=())
|
| offline_file_system.py | 6 from future import Gettable, Future
19 return Future(delegate=Gettable(raise_file_not_found))
|
| future_test.py | 9 from future import Future
13 self.assertRaises(ValueError, Future)
16 future = Future(value=42)
17 self.assertEqual(42, future.Get())
18 self.assertEqual(42, future.Get())
30 future = Future(delegate=delegate())
31 self.assertEqual(42, future.Get()
[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) {
|
| /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(
|
| /packages/apps/Gallery2/src/com/android/gallery3d/ui/ |
| BitmapLoader.java | 22 import com.android.gallery3d.util.Future;
45 private Future<Bitmap> mTask;
49 public void onFutureDone(Future<Bitmap> future) {
52 mBitmap = future.get();
60 if (future.isCancelled() && mBitmap == null) {
106 abstract protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l);
|
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorService.java | 10 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 {
|
