/packages/apps/Gallery2/src/com/android/photos/shims/ |
BitmapJobDrawable.java | 30 import com.android.gallery3d.util.Future; 169 protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l) {
|
MediaItemsLoader.java | 36 import com.android.gallery3d.util.Future; 55 private Future<Integer> mSyncTask = null;
|
MediaSetLoader.java | 33 import com.android.gallery3d.util.Future; 52 private Future<Integer> mSyncTask = null;
|
/frameworks/base/services/tests/servicestests/src/com/android/server/ |
ConnectivityServiceTest.java | 52 import java.util.concurrent.Future; 152 // Future<?> nextConnBroadcast; 172 // Future<?> nextConnBroadcast;
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
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...] |
ExecutorsTest.java | 182 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), 208 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), 236 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), 251 * Future.get on submitted tasks will time out if they compute too long. 271 Future future = executor.submit(sleeper); 272 assertFutureTimesOut(future);
|
ThreadPoolExecutorSubclassTest.java | 1268 Future<String> future = e.submit(new StringTask()); local 1282 Future<?> future = e.submit(new NoOpRunnable()); local 1296 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local [all...] |
ThreadPoolExecutorTest.java | 1398 Future<String> future = e.submit(new StringTask()); local 1415 Future<?> future = e.submit(new NoOpRunnable()); local 1432 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local [all...] |
FutureTaskTest.java | 16 import java.util.concurrent.Future; 26 void checkIsDone(Future<?> f) { 64 void checkNotDone(Future<?> f) { 75 void checkIsRunning(Future<?> f) { 92 <T> void checkCompletedNormally(Future<T> f, T expected) { 104 void checkCancelled(Future<?> f) { 129 void checkCompletedAbnormally(Future<?> f, Throwable t) { 218 * creating a future with a null callable throws NullPointerException 228 * creating a future with null runnable throws NullPointerException
|
/cts/libs/vogar-expect/src/vogar/commands/ |
Command.java | 35 import java.util.concurrent.Future; 185 * @return a future to retrieve the command's output. 187 public Future<List<String>> executeLater() { 189 Future<List<String>> result = executor.submit(new Callable<List<String>>() {
|
/external/chromium_org/chrome/common/extensions/docs/server2/ |
test_file_system.py | 6 from future import Future 123 return Future(value=dict((k, v) for k, v in self._path_values.iteritems() 127 return Future(value=())
|
api_data_source.py | 15 from future import Future, Collect 517 return Future(callback=resolve) 530 return Future(callback=resolve)
|
cron_servlet.py | 17 from future import Future 171 future, init_timer = TimerClosure(target.Cron) 172 assert isinstance(future, Future), ( 173 '%s.Cron() did not return a Future' % title) 177 future.Get() 189 return Future(callback=resolve) 218 for future in cron_futures: 219 future.Get( [all...] |
rietveld_patcher.py | 10 from future import Future 144 return Future(callback=_GetAsyncFetchCallback(self._issue,
|
sidenav_data_source.py | 12 from future import Future
|
api_data_source_test.py | 20 from future import Future 55 return Future(value='handlebar %s' % key)
|
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/compiler-runner/src/org/chromium/devtools/compiler/ |
Runner.java | 23 import java.util.concurrent.Future; 107 List<Future<CompilerRunner>> futures = new ArrayList<>(descriptors.size()); 113 for (Future<CompilerRunner> future : futures) { 115 CompilerRunner task = 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...] |
SlideshowPage.java | 38 import com.android.gallery3d.util.Future; 64 public Future<Slide> nextSlide(FutureListener<Slide> listener); 145 public void onFutureDone(Future<Slide> future) { 146 mPendingSlide = future.get();
|
/external/smali/smali/src/main/java/org/jf/smali/ |
main.java | 49 import java.util.concurrent.Future; 195 List<Future<Boolean>> tasks = Lists.newArrayList(); 210 for (Future<Boolean> task: tasks) {
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
Futures.java | 47 import java.util.concurrent.Future; 56 * Static utility methods pertaining to the {@link Future} interface. 75 * See {@link Future#get()} for details on the exceptions thrown. 80 ListenableFuture<V> future, Function<Exception, X> mapper) { 81 return new MappingCheckedFuture<V, X>(checkNotNull(future), mapper); 86 * construction. The getters just return the value. This {@code Future} can't 91 SettableFuture<V> future = SettableFuture.create(); local 92 future.set(value); 93 return future; 100 * <p>The returned {@code Future} can't be cancelled, and its {@code isDone() 106 SettableFuture<V> future = SettableFuture.create(); local [all...] |
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
AbstractExecutionThreadServiceTest.java | 27 import java.util.concurrent.Future; 172 Future<Service.State> startupFuture = service.start();
|
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/smali/baksmali/src/main/java/org/jf/baksmali/ |
baksmali.java | 139 List<Future<Boolean>> tasks = Lists.newArrayList(); 151 for (Future<Boolean> task: tasks) {
|