| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| SinglePhotoDataAdapter.java | 35 import com.android.gallery3d.util.Future;
48 private Future<?> mTask;
70 onDecodeThumbComplete((Future<Bitmap>) message.obj);
90 public void onFutureDone(Future<BitmapRegionDecoder> future) {
91 BitmapRegionDecoder decoder = future.get();
107 public void onFutureDone(Future<Bitmap> future) {
109 mHandler.obtainMessage(MSG_UPDATE_IMAGE, future));
134 private void onDecodeThumbComplete(Future<Bitmap> future)
[all...] |
| SlideshowDataAdapter.java | 26 import com.android.gallery3d.util.Future;
60 private Future<Void> mReloadTask;
174 public Future<Slide> nextSlide(FutureListener<Slide> listener) {
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| caching_file_system.py | 9 from future import Future
64 return Future(value=make_stat_info(dir_stat))
73 return Future(callback=resolve)
92 # been cached in which case their Future will already have been constructed
96 def swallow_file_not_found_error(future):
98 try: return future.Get()
100 return Future(callback=resolve)
109 stat_future = Future(value=stat_value)
121 return Future(value=fresh_data
[all...] |
| features_bundle.py | 11 from future import Future
89 return Future(value={})
125 return Future(value=api_features)
143 return Future(callback=resolve)
|
| chained_compiled_file_system.py | 8 from future import Future
90 return Future(callback=resolve)
|
| 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)
|
| github_file_system.py | 15 from future import Future
100 self._zip_file = Future(value=None)
104 self._zip_file = Future(value=ZipFile(StringIO(blob)))
108 self._zip_file = Future(value=None)
110 self._zip_file = Future(
159 return Future(value=result)
|
| file_system.py | 8 from future import Future
22 return Future(callback=boom)
80 guaranteed to only happen once the Future has been resolved (Get()
88 '''Reads a single file from the FileSystem. Returns a Future with the same
93 return Future(callback=lambda: read_single.Get()[path])
96 '''Returns a Future to the existence of |path|; True if |path| exists,
106 return Future(value=True)
115 return Future(callback=resolve)
119 future to its completion
[all...] |
| gcs_file_system.py | 11 from future import Future
99 return Future(callback=resolve)
102 return Future(value=())
|
| local_file_system.py | 10 from future import Future
93 return Future(callback=resolve)
96 return Future(value=())
|
| patched_file_system.py | 8 from future import Future
48 return Future(callback=raise_file_not_found)
54 return Future(callback=_GetAsyncFetchCallback(
|
| api_list_data_source.py | 6 from future import Future
101 return Future(callback=resolve)
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 23 import java.util.concurrent.Future;
80 Future s = executor.submit(new Callable<Void>() {
89 Future c = executor.submit(new Callable<Void>() {
|
| /packages/apps/Gallery2/src/com/android/gallery3d/ui/ |
| DetailsAddressResolver.java | 26 import com.android.gallery3d.util.Future;
36 private Future<Address> mAddressLookupJob;
68 public void onFutureDone(final Future<Address> future) {
70 if (!future.isCancelled()) {
74 updateLocation(future.get());
|
| /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...] |
| /external/glide/library/src/main/java/com/bumptech/glide/volley/ |
| VolleyRequestFuture.java | 25 import java.util.concurrent.Future;
32 * A Future that represents a Volley request.
36 * RequestFuture<JSONObject> future = RequestFuture.newFuture();
37 * MyRequest request = new MyRequest(URL, future, future);
40 * future.setRequest(requestQueue.add(request));
46 * JSONObject response = future.get();
55 * @param <T> The type of parsed response this future expects.
57 public class VolleyRequestFuture<T> implements Future<T>, Response.Listener<T>,
|
| /frameworks/volley/src/com/android/volley/toolbox/ |
| RequestFuture.java | 24 import java.util.concurrent.Future;
29 * A Future that represents a Volley request.
33 * RequestFuture<JSONObject> future = RequestFuture.newFuture();
34 * MyRequest request = new MyRequest(URL, future, future);
37 * future.setRequest(requestQueue.add(request));
43 * JSONObject response = future.get();
52 * @param <T> The type of parsed response this future expects.
54 public class RequestFuture<T> implements Future<T>, Response.Listener<T>,
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| ComboAlbum.java | 19 import com.android.gallery3d.util.Future;
100 public Future<Integer> requestSync(SyncListener listener) {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| MoreExecutorsTest.java | 35 import java.util.concurrent.Future;
72 Future<?> future = executor.submit(incrementTask);
73 assertTrue(future.isDone());
83 ListenableFuture<?> future = executor.submit(incrementTask); local
84 assertTrue(future.isDone());
85 assertListenerRunImmediately(future);
113 List<Future<Integer>> futures =
117 Future<Integer> future = futures.get(i) local
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ForkJoinPoolTest.java | 18 import java.util.concurrent.Future;
217 Future<String> future = p.submit(new StringTask()); local
421 Future<?> future = e.submit(task); local
422 assertNull(future.get());
423 assertNull(future.get(0, MILLISECONDS));
425 assertTrue(future.isDone());
426 assertFalse(future.isCancelled());
438 Future<String> future = e.submit(new StringTask()) local
453 Future<?> future = e.submit(new NoOpRunnable()); local
468 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
550 Future<?> future = e.submit((Runnable) null); local
564 Future<String> future = e.submit((Callable) null); local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/ |
| JsDocValidator.java | 14 import java.util.concurrent.Future;
29 List<Future<ValidatorContext>> futures = new ArrayList<>(args.length);
35 for (Future<ValidatorContext> future : futures) {
37 ValidatorContext context = future.get();
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| Uninterruptibles.java | 27 import java.util.concurrent.Future;
118 * Invokes {@code future.}{@link Future#get() get()} uninterruptibly.
123 * with other exceptions, see {@link Futures#get(Future, Class) Futures.get}
126 public static <V> V getUninterruptibly(Future<V> future)
132 return future.get();
146 * {@code future.}{@link Future#get(long, TimeUnit) get(timeout, unit)}
150 * with other exceptions, see {@link Futures#get(Future, Class) Futures.get
[all...] |
| /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();
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/ |
| BroadcastInterceptingContext.java | 33 import java.util.concurrent.Future;
84 public Future<Intent> nextBroadcastIntent(String action) {
88 public Future<Intent> nextBroadcastIntent(IntentFilter filter) {
|
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/ |
| ThreadPool.java | 97 public <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
103 public <T> Future<T> submit(Job<T> job) {
107 private class Worker<T> implements Runnable, Future<T>, JobContext {
148 // Below are the methods for Future.
|
