| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractScheduledServiceTest.java | 27 import java.util.concurrent.Future;
45 volatile ScheduledFuture<?> future = null; field in class:AbstractScheduledServiceTest
55 return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit);
62 assertFalse(future.isDone());
64 assertTrue(future.isCancelled());
82 future.get();
304 Future<?> future = scheduler.schedule(null, Executors.newScheduledThreadPool(10), task); local
312 future.cancel(false);
|
| /external/openssl/crypto/sha/asm/ |
| sha1-armv8.pl | 52 add $d,$d,$K // future e+=K
56 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
69 add $d,$d,$K // future e+=K
74 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
94 add $d,$d,$K // future e+=K
100 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
118 add $d,$d,$K // future e+=K
124 add $d,$d,@Xw[($i+1)&15] // future e+=X[i]
132 add $d,$d,$K // future e+=K
136 add $d,$d,@Xw[($i+1)&15] // future e+=X[i
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ScheduledExecutorTest.java | 51 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
73 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
190 Future f = se.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
750 Future<String> future = e.submit(new StringTask()); local
751 String result = future.get();
764 Future<?> future = e.submit(new NoOpRunnable()); local
765 future.get();
766 assertTrue(future.isDone())
778 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| ScheduledExecutorSubclassTest.java | 103 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
125 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
240 Future f = se.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
799 Future<String> future = e.submit(new StringTask()); local
800 String result = future.get();
813 Future<?> future = e.submit(new NoOpRunnable()); local
814 future.get();
815 assertTrue(future.isDone())
827 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| /external/chromium_org/v8/test/mjsunit/ |
| keywords-and-reserved_words.js | 28 // Test proper handling of keywords, future reserved words and
29 // future reserved words in strict mode as specific by 7.6.1 and 7.6.2
67 // Check for strict mode future reserved words.
141 // In ES5 "const" is a "future reserved word" but we treat it as a keyword.
148 // 7.6.1.2 Future Reserved Words (without "const")
161 // 7.6.1.2 Future Reserved Words, in strict mode only.
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ConcurrentHashMultisetBasherTest.java | 33 import java.util.concurrent.Future;
72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks);
78 for (Future<int[]> future : futures) {
79 int[] taskDeltas = future.get();
|
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| SSLSocketTest.java | 41 import java.util.concurrent.Future;
320 Future<Void> future = executor.submit(new Callable<Void>() { local
351 future.get();
377 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1));
390 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2));
413 Future<Void> future = executor.submit(new Callable<Void>() { local
429 future.get();
443 Future<Void> future = executor.submit(new Callable<Void>() local
463 Future<Void> future = executor.submit(new Callable<Void>() { local
585 Future<Void> future = executor.submit(new Callable<Void>() { local
651 Future<IOException> future = executor.submit(new Callable<IOException>() { local
705 Future<Void> future = executor.submit(new Callable<Void>() { local
735 Future<Void> future = executor.submit(new Callable<Void>() { local
807 Future<Void> future = executor.submit(new Callable<Void>() { local
854 Future<Void> future = executor.submit(new Callable<Void>() { local
896 Future<Void> future = executor.submit(new Callable<Void>() { local
925 Future<Void> future = executor.submit(new Callable<Void>() { local
1227 Future<Void> future = executor.submit(new Callable<Void>() { local
1290 Future<Void> future = executor.submit(new Callable<Void>() { local
1317 Future<Void> future = executor.submit(new Callable<Void>() { local
1357 Future<Void> future = executor.submit(new Callable<Void>() { local
[all...] |
| /packages/apps/Email/tests/src/com/android/email/ |
| AccountTestCase.java | 87 AccountManagerFuture<Boolean> future = local
90 future.getResult();
|
| /build/target/product/ |
| core_minimal.mk | 35 com.android.future.usb.accessory \
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| manifest_data_source_test.py | 10 from future import Future
284 return Future(value=manifest_features)
|
| schema_processor_test.py | 10 from future import Future
25 return Future(value={})
|
| template_data_source.py | 14 from future import All
|
| test_object_store.py | 5 from future import Future
12 is a special case; it is only incremented once the future has had Get called.
32 return Future(callback=callback)
|
| gitiles_file_system.py | 22 from future import All, Future
88 '''Returns a future to cleanly resolve |fetch_future|.
143 # A list of tuples of the form (path, Future).
157 return All(self._ResolveFetchContent(path, future, skip_not_found)
158 for path, future in fetches).Then(parse_contents)
161 return Future(value=())
201 '''Returns a future that resolves to the commit ID for this branch.
206 '''Returns a future that resolves to the previous commit ID for this branch.
|
| subversion_file_system.py | 15 from future import Future
137 # A list of tuples of the form (path, Future).
143 for path, future in fetches:
145 result = future.Get()
165 return Future(callback=resolve)
168 return Future(value=())
202 return Future(callback=resolve)
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/nouveau/ |
| nouveau_video.h | 39 unsigned past, future, current; member in struct:nouveau_decoder
|
| /external/libcxx/test/thread/futures/futures.shared_future/ |
| move_assign.pass.cpp | 10 // <future>
16 #include <future>
|
| move_ctor.pass.cpp | 10 // <future>
16 #include <future>
|
| /external/mesa3d/src/gallium/drivers/nouveau/ |
| nouveau_video.h | 39 unsigned past, future, current; member in struct:nouveau_decoder
|
| /frameworks/base/libs/usb/src/com/android/future/usb/ |
| UsbAccessory.java | 17 package com.android.future.usb;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.shared_future/ |
| move_assign.pass.cpp | 10 // <future>
16 #include <future>
|
| move_ctor.pass.cpp | 10 // <future>
16 #include <future>
|
| /cts/tests/tests/media/src/android/media/cts/ |
| MediaPlayerFlakyNetworkTest.java | 222 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable); local
223 getInstrumentation().runOnMainSync(future);
224 return future.get();
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| LocalAlbumSet.java | 27 import com.android.gallery3d.util.Future;
58 private Future<ArrayList<MediaSet>> mLoadTask;
184 public synchronized void onFutureDone(Future<ArrayList<MediaSet>> future) {
185 if (mLoadTask != future) return; // ignore, wait for the latest task
186 mLoadBuffer = future.get();
|
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| PhotoDataAdapter.java | 38 import com.android.gallery3d.util.Future;
295 private void updateScreenNail(Path path, Future<ScreenNail> future) {
297 ScreenNail screenNail = future.get();
299 if (entry == null || entry.screenNailTask != future) {
330 private void updateFullImage(Path path, Future<BitmapRegionDecoder> future) {
332 if (entry == null || entry.fullImageTask != future) {
333 BitmapRegionDecoder fullImage = future.get();
339 entry.fullImage = future.get()
[all...] |
