| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| object_store.py | 5 from future import Future
19 '''Gets a |Future| with the value of |key| in the object store, or None
22 return Future(delegate=_SingleGetFuture(self.GetMulti([key]), key))
25 '''Gets a |Future| with values mapped to |keys| from the object store, with
|
| template_data_source.py | 11 from future import Future
34 return Future(value=())
|
| test_patcher.py | 5 from future import Future
29 return Future(value=dict((path, self._patch_data[path])
|
| cache_chain_object_store.py | 5 from future import Future
9 '''A Future for GetMulti.
13 - |object_store_futures| a list of (object store, future) pairs, where future
32 # Don't realise the Future value of an object store that we don't need to;
92 return Future(value=cached_items)
95 return Future(delegate=_GetMultiFuture(
|
| chroot_file_system.py | 9 from future import Gettable, Future
40 return Future(delegate=Gettable(resolve))
|
| intro_data_source.py | 12 from future import Future
59 return Future(value=())
|
| manifest_data_source_test.py | 10 from future import Future
284 return Future(value=manifest_features)
|
| persistent_object_store.py | 8 from future import Future
19 return dict((key, future.get_result().GetValue())
20 for key, future in self._futures.iteritems()
21 if future.get_result() is not None)
37 [future.wait() for future in futures]
40 return Future(delegate=_AsyncGetFuture(self, keys))
50 [future.wait() for future in futures
[all...] |
| compiled_file_system.py | 10 from future import Gettable, Future
148 '''Returns a Future containing the recursive directory listing of |path| as
164 # asynchronous Future contract) because there's a greater chance to
170 return Future(exc_info=sys.exc_info())
173 return Future(value=first_layer_files)
200 return Future(delegate=Gettable(resolve))
211 return Future(exc_info=sys.exc_info())
215 return Future(value=cache_entry._cache_data)
222 return Future(delegate=Gettable(resolve)
[all...] |
| /external/junit/src/org/junit/experimental/ |
| ParallelComputer.java | 8 import java.util.concurrent.Future;
38 private final List<Future<Object>> fResults= new ArrayList<Future<Object>>();
53 for (Future<Object> each : fResults)
|
| /frameworks/base/core/java/android/accounts/ |
| AccountManagerFuture.java | 18 import java.util.concurrent.Future;
34 * If you would like to use a <tt>Future</tt> for the sake
36 * declare types of the form <tt>Future<?></tt> and
83 * Accessor for the future result the {@link AccountManagerFuture} represents. This
99 * Accessor for the future result the {@link AccountManagerFuture} represents. This
|
| /external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/ |
| JsDocValidator.java | 15 import java.util.concurrent.Future;
38 List<Future<ValidatorContext>> futures = new ArrayList<>(args.length);
44 for (Future<ValidatorContext> future : futures) {
46 ValidatorContext result = future.get();
|
| /external/robolectric/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...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| PanoramaMetadataSupport.java | 21 import com.android.gallery3d.util.Future;
35 private Future<PanoramaMetadata> mGetPanoMetadataTask;
78 public void onFutureDone(Future<PanoramaMetadata> future) {
80 mPanoramaMetadata = future.get();
|
| 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...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| CheckedFuture.java | 23 import java.util.concurrent.Future;
30 * easier to create a future that executes logic which can throw an exception.
35 * {@code Future#get()}: {@link CancellationException},
40 * listeners to be added. This allows the future to be used as a normal
41 * {@link Future} or as an asynchronous callback mechanism as needed. This
43 * future will guarantee execution of all listeners when the task completes.
45 * <p>For a simpler alternative to CheckedFuture, consider accessing Future
46 * values with {@link Futures#get(Future, Class) Futures.get()}.
56 * Exception checking version of {@link Future#get()} that will translate
60 * @return the result of executing the future
[all...] |
| AbstractScheduledService.java | 25 import java.util.concurrent.Future;
120 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
139 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
147 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
158 private volatile Future<?> runningTask;
329 /** The future that represents the next execution of this task.*/
331 private Future<Void> currentFuture;
348 * Atomically reschedules this task and assigns the new future to {@link #currentFuture}.
352 // cancel calls cancel on the correct future. 2. we want to make sure that the assignment
364 // because the service does not monitor the state of the future so if the exception is no
[all...] |
| /packages/apps/ContactsCommon/src/com/android/contacts/common/vcard/ |
| ProcessorBase.java | 19 import java.util.concurrent.Future;
31 * {@link #get()} and {@link #get(long, TimeUnit)}, which are form {@link Future}, aren't
51 * @see Future#cancel(boolean)
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| MediaSet.java | 20 import com.android.gallery3d.util.Future;
232 * Requests sync on this MediaSet. It returns a Future object that can be used by the caller
234 * defined in this class and can be obtained by Future.get().
238 * The default implementation here returns a Future stub that does nothing and returns
241 public Future<Integer> requestSync(SyncListener listener) {
246 private static final Future<Integer> FUTURE_STUB = new Future<Integer>() {
269 protected Future<Integer> requestSyncOnMultipleSets(MediaSet[] sets, SyncListener listener) {
273 private class MultiSetSyncFuture implements Future<Integer>, SyncListener {
278 private final Future<Integer> mFutures[]
[all...] |
| ComboAlbumSet.java | 21 import com.android.gallery3d.util.Future;
93 public Future<Integer> requestSync(SyncListener listener) {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractListeningExecutorServiceTest.java | 29 import java.util.concurrent.Future;
61 Future<?> future = e.submit(task); local
62 future.get();
71 Future<String> future = e.submit(new StringTask()); local
72 String result = future.get();
81 Future<?> future = e.submit(new NoOpRunnable()); local
82 future.get()
91 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| /external/jmonkeyengine/engine/src/core/com/jme3/scene/control/ |
| UpdateControl.java | 40 import java.util.concurrent.Future;
64 public <V> Future<V> enqueue(Callable<V> callable) {
|
| /sdk/emulator/qtools/ |
| trace_reader_base.h | 172 struct Future {
173 Future *next;
177 inline Future *AllocFuture();
178 inline void FreeFuture(Future *future);
179 inline void InsertFuture(Future *future);
183 Future futures_[kMaxNumBasicBlocks];
184 Future *head_;
185 Future *free_
[all...] |
| /libcore/support/src/test/java/tests/support/ |
| Support_Exec.java | 33 import java.util.concurrent.Future;
87 Future<String> errFuture = executorService.submit(
89 Future<String> outFuture = executorService.submit(
127 Future<String> errFuture =
129 Future<String> outFuture =
|
| /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...] |
