| /libcore/luni/src/main/java/java/util/concurrent/ |
| CompletionService.java | 35 * Submits a value-returning task for execution and returns a Future
40 * @return a Future representing pending completion of the task
45 Future<V> submit(Callable<V> task);
48 * Submits a Runnable task for execution and returns a Future
54 * @return a Future representing pending completion of the task,
61 Future<V> submit(Runnable task, V result);
64 * Retrieves and removes the Future representing the next
67 * @return the Future representing the next completed task
70 Future<V> take() throws InterruptedException;
74 * 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 <tt>run</tt> method causes completion of the <tt>Future</tt>
17 * @param <V> The result type returned by this Future's <tt>get</tt> 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()}.
176 * Future representing the pending results of the task. The
177 * Future's <tt>get</tt> method will return the task's result upon
191 * @return a Future representing pending completion of the task
196 <T> Future<T> submit(Callable<T> task);
199 * Submits a Runnable task for execution and returns a Future
200 * representing that task. The Future's <tt>get</tt> method will
205 * @return a Future representing pending completion of the tas
[all...] |
| AbstractExecutorService.java | 49 * @param value the default value for the returned future
51 * underlying runnable and which, as a <tt>Future</tt>, will yield
65 * underlying callable and which, as a <tt>Future</tt>, 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 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks);
141 Future<T> f = ecs.poll();
178 for (Future<T> f : futures
[all...] |
| Future.java | 10 * A <tt>Future</tt> represents the result of an asynchronous
19 * If you would like to use a <tt>Future</tt> 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 <tt>Future</tt> that
50 * FutureTask<String> future =
55 * executor.execute(future);}</pre
[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/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 {
|
| /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)
|
| /frameworks/base/core/java/android/accounts/ |
| AccountManagerFuture.java | 18 import java.util.concurrent.Future;
34 * If you would like to use a <tt>Future</tt> for the sake
36 * declare types of the form <tt>Future<?></tt> and
83 * Accessor for the future result the {@link AccountManagerFuture} represents. This
99 * Accessor for the future result the {@link AccountManagerFuture} represents. This
|
| /external/robolectric/src/test/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorServiceTest.java | 10 import java.util.concurrent.Future;
47 Future<String> future = executorService.submit(runnable, "foo"); local
50 assertFalse(future.isDone());
54 assertTrue(future.isDone());
56 assertEquals("foo", future.get());
61 Future<String> future = executorService.submit(new Callable<String>() { local
69 assertFalse(future.isDone());
73 assertTrue(future.isDone())
[all...] |
