| /external/dagger2/producers/src/test/java/dagger/producers/internal/ |
| ProducersTest.java | 40 ListenableFuture<String> future = Futures.immediateFuture("monkey"); local
41 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future);
47 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); local
48 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future);
54 ListenableFuture<String> future = SettableFuture.create(); local
55 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future);
58 assertThat(future.isCancelled()).isTrue();
62 ListenableFuture<String> future = SettableFuture.create(); local
63 ListenableFuture<Produced<String>> producedFuture = Producers.createFutureProduced(future);
65 future.cancel(false)
81 ListenableFuture<String> future = Futures.immediateFuture("monkey"); local
88 ListenableFuture<String> future = Futures.immediateFailedFuture(new RuntimeException("monkey")); local
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AsyncSettableFuture.java | 24 * A settable future that can be set asynchronously via {@link #setFuture}.
26 * future that sets a normal settable future after the delegate is complete.
30 * as improved cancellation semantics (i.e. if either future is cancelled,
33 * @param <V> The result type returned by the Future's {@code get} method.
39 /** Creates a new asynchronously-settable future. */
54 * Sets this future to forward to the given future. Returns {@code true}
55 * if the future was able to be set (i.e. it hasn't been set already).
57 public boolean setFuture(ListenableFuture<? extends V> future) {
[all...] |
| Futures.java | 50 import java.util.concurrent.Future;
62 * Static utility methods pertaining to the {@link Future} interface.
86 * See {@link Future#get()} for details on the exceptions thrown.
91 ListenableFuture<V> future, Function<? super Exception, X> mapper) {
92 return new MappingCheckedFuture<V, X>(checkNotNull(future), mapper);
199 this.thrown = new CancellationException("Immediate cancelled future.");
242 * construction. The getters just return the value. This {@code Future} can't
254 * <p>The returned {@code Future} can't be cancelled, and its {@code isDone()}
267 * <p>The returned {@code Future} can't be cancelled, and its {@code isDone()}
292 * <p>The returned {@code Future} can't be cancelled, and its {@code isDone()
[all...] |
| AsyncFunction.java | 19 import java.util.concurrent.Future;
30 * Returns an output {@code Future} to use in place of the given {@code
31 * input}. The output {@code Future} need not be {@linkplain Future#isDone
35 * failing {@code Future}.
|
| 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...] |
| /external/robolectric/v1/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 {
|
| /frameworks/base/core/tests/coretests/src/android/animation/ |
| AutoCancelTest.java | 59 private void setupAnimators(long startDelay, boolean startLater, final FutureWaiter future)
82 future.set(false);
96 future.set(false);
103 // Release future if not done already via failures during start
104 future.release();
125 final FutureWaiter future = new FutureWaiter(); local
130 setupAnimators(0, false, future);
132 future.setException(e);
136 assertTrue(future.get(FUTURE_TIMEOUT, TimeUnit.MILLISECONDS));
141 final FutureWaiter future = new FutureWaiter() local
157 final FutureWaiter future = new FutureWaiter(); local
173 final FutureWaiter future = new FutureWaiter(); local
[all...] |
| /external/libcxx/test/std/thread/futures/futures.shared_future/ |
| ctor_future.pass.cpp | 12 // <future>
16 // shared_future(future<R>&& rhs);
18 #include <future>
26 std::future<T> f0 = p.get_future();
33 std::future<T> f0;
41 std::future<T> f0 = p.get_future();
48 std::future<T> f0;
56 std::future<T> f0 = p.get_future();
63 std::future<T> f0;
|
| /external/libcxx/test/std/thread/futures/futures.unique_future/ |
| share.pass.cpp | 12 // <future>
14 // class future<R>
18 #include <future>
26 std::future<T> f0 = p.get_future();
33 std::future<T> f0;
41 std::future<T> f0 = p.get_future();
48 std::future<T> f0;
56 std::future<T> f0 = p.get_future();
63 std::future<T> f0;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.shared_future/ |
| ctor_future.pass.cpp | 10 // <future>
14 // shared_future(future<R>&& rhs);
16 #include <future>
24 std::future<T> f0 = p.get_future();
31 std::future<T> f0;
39 std::future<T> f0 = p.get_future();
46 std::future<T> f0;
54 std::future<T> f0 = p.get_future();
61 std::future<T> f0;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.unique_future/ |
| share.pass.cpp | 10 // <future>
12 // class future<R>
16 #include <future>
24 std::future<T> f0 = p.get_future();
31 std::future<T> f0;
39 std::future<T> f0 = p.get_future();
46 std::future<T> f0;
54 std::future<T> f0 = p.get_future();
61 std::future<T> f0;
|
| /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/messageformat/java/com/ibm/icu/util/ |
| ICUCloneNotSupportedException.java | 15 * @provisional This API might change or be removed in a future release.
24 * @provisional This API might change or be removed in a future release.
34 * @provisional This API might change or be removed in a future release.
45 * @provisional This API might change or be removed in a future release.
57 * @provisional This API might change or be removed in a future release.
|
| ICUException.java | 13 * @provisional This API might change or be removed in a future release.
22 * @provisional This API might change or be removed in a future release.
32 * @provisional This API might change or be removed in a future release.
43 * @provisional This API might change or be removed in a future release.
55 * @provisional This API might change or be removed in a future release.
|
| ICUUncheckedIOException.java | 19 * @provisional This API might change or be removed in a future release.
28 * @provisional This API might change or be removed in a future release.
38 * @provisional This API might change or be removed in a future release.
49 * @provisional This API might change or be removed in a future release.
61 * @provisional This API might change or be removed in a future release.
|
| /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 | 23 #include "Future.h"
37 Task(): mFuture(new Future<T>()) { }
49 const sp<Future<T> >& future() const { function in class:android::uirenderer::Task
54 sp<Future<T> > mFuture;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.promise/ |
| default.pass.cpp | 10 // <future>
16 #include <future>
23 std::future<int> f = p.get_future();
28 std::future<int&> f = p.get_future();
33 std::future<void> f = p.get_future();
|
| get_future.pass.cpp | 10 // <future>
14 // future<R> get_future();
16 #include <future>
23 std::future<double> f = p.get_future();
29 std::future<double> f = p.get_future();
45 std::future<double> f = p.get_future();
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| 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/junit/src/org/junit/runners/ |
| JUnit4.java | 6 * Aliases the current default JUnit 4 class runner, for future-proofing. If
7 * future versions of JUnit change the default Runner class, they will also
13 * in future versions.
|
| /external/libcxx/test/std/thread/futures/futures.promise/ |
| get_future.pass.cpp | 12 // <future>
16 // future<R> get_future();
18 #include <future>
25 std::future<double> f = p.get_future();
31 std::future<double> f = p.get_future();
47 std::future<double> f = p.get_future();
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/compiler/ |
| future.py | 1 """Parser for future statements
8 """Return true if statement is a well-formed future statement"""
38 "future feature %s is not defined" % name
44 """Return list of features enabled by future statements"""
48 """Check for invalid future statements"""
55 raise SyntaxError, "invalid future statement " + repr(node)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/compiler/ |
| future.py | 1 """Parser for future statements
8 """Return true if statement is a well-formed future statement"""
38 "future feature %s is not defined" % name
44 """Return list of features enabled by future statements"""
48 """Check for invalid future statements"""
55 raise SyntaxError, "invalid future statement " + repr(node)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/compiler/ |
| future.py | 1 """Parser for future statements
8 """Return true if statement is a well-formed future statement"""
38 "future feature %s is not defined" % name
44 """Return list of features enabled by future statements"""
48 """Check for invalid future statements"""
55 raise SyntaxError, "invalid future statement " + repr(node)
|
