| /external/libcxx/test/std/thread/futures/futures.promise/ |
| set_lvalue.pass.cpp | 13 // <future>
19 #include <future>
30 std::future<T> f = p.get_future();
|
| set_rvalue_at_thread_exit.pass.cpp | 12 // <future>
18 #include <future>
31 std::future<std::unique_ptr<int>> f = p.get_future();
|
| dtor.pass.cpp | 13 // <future>
19 #include <future>
28 std::future<T> f;
39 std::future<T> f;
60 std::future<T> f;
71 std::future<T> f;
91 std::future<T> f;
103 std::future<T> f;
|
| set_rvalue.pass.cpp | 13 // <future>
19 #include <future>
36 std::future<T> f = p.get_future();
53 std::future<T> f = p.get_future();
|
| set_value_const.pass.cpp | 13 // <future>
19 #include <future>
38 std::future<T> f = p.get_future();
59 std::future<T> f = p.get_future();
|
| /external/parameter-framework/upstream/remote-processor/ |
| BackgroundRemoteProcessorServer.h | 33 #include <future>
55 std::future<bool> mServerSuccess;
|
| /external/robolectric/v1/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...] |
| /external/testng/src/main/java/org/testng/internal/thread/ |
| FutureResultAdapter.java | 5 import java.util.concurrent.Future;
8 * A very reduced interface of <code>Future</code>.
13 Future<?> m_future;
15 public FutureResultAdapter(Future<?> future) {
16 m_future = future;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/thread/futures/futures.promise/ |
| set_exception.pass.cpp | 14 // <future>
20 #include <future>
28 std::future<T> f = p.get_future();
|
| set_exception_at_thread_exit.pass.cpp | 14 // <future>
20 #include <future>
33 std::future<T> f = p.get_future();
|
| set_lvalue.pass.cpp | 13 // <future>
19 #include <future>
30 std::future<T> f = p.get_future();
|
| set_rvalue_at_thread_exit.pass.cpp | 12 // <future>
18 #include <future>
31 std::future<std::unique_ptr<int>> f = p.get_future();
|
| dtor.pass.cpp | 13 // <future>
19 #include <future>
28 std::future<T> f;
39 std::future<T> f;
60 std::future<T> f;
71 std::future<T> f;
91 std::future<T> f;
103 std::future<T> f;
|
| /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/libcxx/test/std/thread/futures/futures.shared_future/ |
| ctor_future.pass.cpp | 13 // <future>
17 // shared_future(future<R>&& rhs);
19 #include <future>
27 std::future<T> f0 = p.get_future();
34 std::future<T> f0;
42 std::future<T> f0 = p.get_future();
49 std::future<T> f0;
57 std::future<T> f0 = p.get_future();
64 std::future<T> f0;
|
| /external/libcxx/test/std/thread/futures/futures.unique_future/ |
| share.pass.cpp | 13 // <future>
15 // class future<R>
19 #include <future>
27 std::future<T> f0 = p.get_future();
35 std::future<T> f0;
44 std::future<T> f0 = p.get_future();
52 std::future<T> f0;
61 std::future<T> f0 = p.get_future();
69 std::future<T> f0;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/thread/futures/futures.shared_future/ |
| ctor_future.pass.cpp | 13 // <future>
17 // shared_future(future<R>&& rhs);
19 #include <future>
27 std::future<T> f0 = p.get_future();
34 std::future<T> f0;
42 std::future<T> f0 = p.get_future();
49 std::future<T> f0;
57 std::future<T> f0 = p.get_future();
64 std::future<T> f0;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/thread/futures/futures.unique_future/ |
| share.pass.cpp | 13 // <future>
15 // class future<R>
19 #include <future>
27 std::future<T> f0 = p.get_future();
35 std::future<T> f0;
44 std::future<T> f0 = p.get_future();
52 std::future<T> f0;
61 std::future<T> f0 = p.get_future();
69 std::future<T> f0;
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| TestingExecutorsTest.java | 29 import java.util.concurrent.Future;
48 ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule( local
52 assertFalse(future.isDone());
73 List<Future<Boolean>> futureList = executor.invokeAll(
75 Future<Boolean> future = futureList.get(0); local
77 assertTrue(future.isDone());
79 future.get();
94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule local
107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); local
[all...] |
| /external/python/cpython3/Lib/concurrent/futures/ |
| _base.py | 16 # Possible future states (for internal use by the futures package).
19 # The future was cancelled by the user...
45 """Base class for all future-related exceptions."""
49 """The Future was cancelled."""
62 def add_result(self, future):
63 self.finished_futures.append(future)
65 def add_exception(self, future):
66 self.finished_futures.append(future)
68 def add_cancelled(self, future):
69 self.finished_futures.append(future)
[all...] |
| /external/libcxx/test/std/thread/futures/futures.task/futures.task.members/ |
| ctor_func.pass.cpp | 13 // <future>
20 #include <future>
48 std::future<double> f = p.get_future();
60 std::future<double> f = p.get_future();
69 std::future<int> f = p.get_future();
76 std::future<int> f = p.get_future();
|
| dtor.pass.cpp | 13 // <future>
19 #include <future>
48 std::future<double> f = p.get_future();
64 std::future<double> f = p.get_future();
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| Invoker.java | 280 static <V,A> void invokeUnchecked(PendingFuture<V,A> future) {
281 assert future.isDone();
282 CompletionHandler<V,? super A> handler = future.handler();
285 future.attachment(),
286 future.value(),
287 future.exception());
296 static <V,A> void invoke(PendingFuture<V,A> future) {
297 assert future.isDone();
298 CompletionHandler<V,? super A> handler = future.handler();
300 invoke(future.channel()
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/thread/futures/futures.task/futures.task.members/ |
| ctor_func.pass.cpp | 13 // <future>
20 #include <future>
48 std::future<double> f = p.get_future();
60 std::future<double> f = p.get_future();
69 std::future<int> f = p.get_future();
76 std::future<int> f = p.get_future();
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| GcFinalizationTest.java | 53 final SettableFuture<Void> future = SettableFuture.create(); local
55 @Override protected void finalize() { future.set(null); }
58 GcFinalization.awaitDone(future);
59 assertTrue(future.isDone());
60 assertFalse(future.isCancelled());
64 final SettableFuture<Void> future = SettableFuture.create(); local
66 @Override protected void finalize() { future.cancel(false); }
69 GcFinalization.awaitDone(future);
70 assertTrue(future.isDone());
71 assertTrue(future.isCancelled())
144 final SettableFuture<Void> future = SettableFuture.create(); local
[all...] |
