| /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();
|
| /sdk/emulator/qtools/ |
| trace_reader.cpp | 74 inline BBReader::Future *BBReader::AllocFuture()
76 Future *future = free_; local
78 return future;
81 inline void BBReader::FreeFuture(Future *future)
83 future->next = free_;
84 free_ = future;
87 inline void BBReader::InsertFuture(Future *future)
197 Future *future = head_; local
222 Future *future = AllocFuture(); local
245 Future *future = head_; local
[all...] |
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| cron_servlet.py | 17 from future import Gettable, Future
159 future, init_timer = TimerClosure(target.Cron)
160 assert isinstance(future, Future), (
161 '%s.Cron() did not return a Future' % title)
165 future.Get()
177 return Future(delegate=Gettable(resolve))
221 for future in cron_futures:
222 future.Get(
[all...] |
| rietveld_patcher.py | 10 from future import Future
149 return Future(delegate=_AsyncFetchFuture(self._issue,
|
| api_data_source_test.py | 17 from future import Future
89 return Future(value='handlebar %s' % key)
|
| /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...] |
| AbstractServiceTest.java | 27 import java.util.concurrent.Future;
116 Thread.interrupted(); // clear interrupt for future tests
342 Future<Service.State> stopResult = service.stop();
346 Future<Service.State> startResult = service.start();
|
| /packages/apps/Gallery2/src/com/android/photos/shims/ |
| 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;
|
| /packages/apps/Gallery2/src/com/android/gallery3d/data/ |
| DownloadCache.java | 29 import com.android.gallery3d.util.Future;
262 private Future<File> mFuture;
286 public void onFutureDone(Future<File> future) {
287 File file = future.get();
293 if (future.isCancelled()) {
|
| /cts/tests/tests/security/src/android/security/cts/ |
| OpenSSLEarlyCCSTest.java | 47 import java.util.concurrent.Future;
199 Future<Void> serverFuture = mExecutorService.submit(new Callable<Void>() {
207 Future<Void> clientFuture = mExecutorService.submit(new Callable<Void>() {
344 Future<Void> serverToClientTask = mExecutorService.submit(new Callable<Void>() {
|
| /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/chromium_org/v8/test/webkit/ |
| keywords-and-reserved_words.js | 59 // Check for strict mode future reserved words.
118 // Technically these are "Future Reserved Words"!
127 // Future Reserved Words, in strict mode only.
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| AbstractListenableFutureTest.java | 29 import java.util.concurrent.Future;
44 protected ListenableFuture<Boolean> future; field in class:AbstractListenableFutureTest
49 // Create a latch and a future that waits on the latch.
51 future = createListenableFuture(Boolean.TRUE, null, latch);
62 * Constructs a listenable future with a value available after the latch
69 * Tests that the {@link Future#get()} method blocks until a value is
74 assertFalse(future.isDone());
75 assertFalse(future.isCancelled());
80 // Wait on the future in a separate thread.
85 assertSame(Boolean.TRUE, future.get())
[all...] |
| /external/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.
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 299 * the future, the variable can be changed to be an AtomicLong,
[all...] |
| ScheduledThreadPoolExecutor.java | 583 * thrown by such a task can be obtained via {@link Future#get}.
601 public Future<?> submit(Runnable task) {
609 public <T> Future<T> submit(Runnable task, T result) {
617 public <T> Future<T> submit(Callable<T> task) {
727 * {@code true}, future executions of existing periodic tasks will
[all...] |
| /external/guava/guava-tests/test/com/google/common/collect/ |
| QueuesTest.java | 29 import java.util.concurrent.Future;
112 Future<?> submitter = threadPool.submit(new Producer(q, 1));
|
| /external/jmonkeyengine/engine/src/core/com/jme3/app/ |
| Application.java | 52 import java.util.concurrent.Future;
564 public <V> Future<V> enqueue(Callable<V> callable) {
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTest.java | 35 import java.util.concurrent.Future;
301 public Future<byte[]> enqueue(final byte[] sendBytes, final int receiveByteCount)
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| CopyOnWriteArrayListTest.java | 29 import java.util.concurrent.Future;
180 Future<?> future = executor.submit(new Runnable() { local
199 future.get(); // this will throw the above exception
|
| /external/jmonkeyengine/engine/src/bullet/com/jme3/bullet/ |
| PhysicsSpace.java | 56 import java.util.concurrent.Future;
368 public static <V> Future<V> enqueueOnThisThread(Callable<V> callable) {
381 public <V> Future<V> enqueue(Callable<V> callable) {
[all...] |
