| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.unique_future/ |
| get.pass.cpp | 10 // <future>
12 // class future<R>
14 // R future::get();
15 // R& future<R&>::get();
16 // void future<void>::get();
18 #include <future>
66 std::future<T> f = p.get_future();
74 std::future<T> f = p.get_future();
93 std::future<T> f = p.get_future();
101 std::future<T> f = p.get_future()
[all...] |
| wait.pass.cpp | 10 // <future>
12 // class future<R>
16 #include <future>
47 std::future<T> f = p.get_future();
61 std::future<T> f = p.get_future();
75 std::future<T> f = p.get_future();
|
| wait_for.pass.cpp | 10 // <future>
12 // class future<R>
18 #include <future>
50 std::future<T> f = p.get_future();
66 std::future<T> f = p.get_future();
82 std::future<T> f = p.get_future();
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| AbstractExecutorServiceTest.java | 49 Future<?> future = e.submit(task); local
50 assertNull(future.get());
51 assertNull(future.get(0, MILLISECONDS));
53 assertTrue(future.isDone());
54 assertFalse(future.isCancelled());
62 Future<String> future = e.submit(new StringTask()); local
63 String result = future.get();
72 Future<?> future = e.submit(new NoOpRunnable()) local
82 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| caching_file_system_test.py | 87 # The stat/read should happen before resolving the Future, and resolving
88 # the future shouldn't do any additional work.
108 future = file_system.ReadSingle('bob/bob0')
110 self.assertEqual('bob/bob0 contents', future.Get())
123 tuple(future.Get() for future in futures))
139 tuple(future.Get() for future in futures))
154 future = file_system.ReadSingle('bob/bob0')
156 self.assertEqual('bob/bob0 contents', future.Get()
[all...] |
| mock_file_system_test.py | 28 '''Returns a function which calls Future.Get on the result of |fn|.
40 future = fs.ReadSingle('apps/')
42 future.Get()
47 future = fs.ReadSingle('apps/')
49 future.Get()
60 future = fs.Read(['notfound.html', 'apps/'])
62 self.assertRaises(FileNotFoundError, future.Get)
|
| 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)
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| FuturesTest.java | 57 import java.util.concurrent.Future;
85 * Clear interrupt for future tests.
96 ListenableFuture<String> future = Futures.immediateFuture(DATA1); local
99 assertSame(DATA1, future.get(0L, TimeUnit.MILLISECONDS));
113 ListenableFuture<String> future = local
117 future.get(0L, TimeUnit.MILLISECONDS);
128 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture( local
132 assertSame(DATA1, future.get(0L, TimeUnit.MILLISECONDS));
133 assertSame(DATA1, future.checkedGet(0L, TimeUnit.MILLISECONDS));
151 CheckedFuture<String, MyException> future local
186 ListenableFuture<FooChild> future = Futures.immediateFuture(null); local
[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...] |
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| FaultTolerantNegotiator.java | 85 List<Future<InputStream>> futures = new ArrayList<Future<InputStream>>();
94 Future<InputStream> future; local
97 future = service.poll(10, TimeUnit.SECONDS);
103 if (future == null) {
108 stream = future.get();
119 for (Future<InputStream> future : futures) {
120 future.cancel(true)
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| JobLimiter.java | 41 private static class JobWrapper<T> implements Future<T>, Job<T> {
44 private Future<T> mDelegate;
53 public synchronized void setFuture(Future<T> future) {
55 mDelegate = future;
136 public synchronized <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
137 JobWrapper<T> future = new JobWrapper<T>(Utils.checkNotNull(job), listener); local
138 mJobs.addLast(future);
140 return future;
155 public synchronized void onFutureDone(Future future)
[all...] |
| /external/zxing/qr_scanner/src/com/google/zxing/client/android/ |
| InactivityTimer.java | 75 ScheduledFuture<?> future = inactivityFuture; local
76 if (future != null) {
77 future.cancel(true);
|
| /external/clang/INPUTS/ |
| all-std-headers.cpp | 66 #if __has_include(<future>)
67 #include <future>
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| GcFinalization.java | 27 import java.util.concurrent.Future;
110 * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage
115 public static void awaitDone(Future<?> future) {
116 if (future.isDone()) {
123 if (future.isDone()) {
128 future.get(1L, SECONDS);
135 throw new RuntimeException("Unexpected interrupt while waiting for future", ie);
141 String.format("Future not done within %d second timeout", timeoutSeconds))
[all...] |
| /external/libcxx/test/thread/futures/futures.future_error/ |
| what.pass.cpp | 10 // <future>
16 #include <future>
29 assert(std::strcmp(f.what(), "The future has already been retrieved from "
|
| /external/libcxx/test/thread/futures/futures.unique_future/ |
| wait.pass.cpp | 10 // <future>
12 // class future<R>
16 #include <future>
47 std::future<T> f = p.get_future();
61 std::future<T> f = p.get_future();
75 std::future<T> f = p.get_future();
|
| wait_for.pass.cpp | 10 // <future>
12 // class future<R>
18 #include <future>
50 std::future<T> f = p.get_future();
66 std::future<T> f = p.get_future();
82 std::future<T> f = p.get_future();
|
| /frameworks/base/libs/hwui/thread/ |
| Task.h | 23 #include "Future.h"
37 Task(): mFuture(new Future<T>()) { }
50 const sp<Future<T> >& future() const { function in class:android::uirenderer::Task
55 sp<Future<T> > mFuture;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.future_error/ |
| what.pass.cpp | 17 // <future>
23 #include <future>
36 assert(std::strcmp(f.what(), "The future has already been retrieved from "
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.6/x86_64-linux/include/c++/4.6/backward/ |
| backward_warning.h | 35 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/x86_64-linux/include/c++/4.8/backward/ |
| backward_warning.h | 34 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/gcc/linux-x86/host/x86_64-w64-mingw32-4.8/x86_64-w64-mingw32/include/c++/4.8.3/backward/ |
| backward_warning.h | 34 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/ndk/5/sources/cxx-stl/gnu-libstdc++/include/backward/ |
| backward_warning.h | 30 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/ndk/6/sources/cxx-stl/gnu-libstdc++/include/backward/ |
| backward_warning.h | 30 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/ndk/7/sources/cxx-stl/gnu-libstdc++/include/backward/ |
| backward_warning.h | 30 may be removed without further notice at a future date. Please use a \
|
