/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 \
|