| /packages/apps/Email/tests/src/com/android/email/ |
| AccountTestCase.java | 82 AccountManagerFuture<Boolean> future = local
85 future.getResult();
|
| /external/guava/src/com/google/common/util/concurrent/ |
| SimpleTimeLimiter.java | 33 import java.util.concurrent.Future;
120 Future<T> future = executor.submit(callable); local
124 return future.get(timeoutDuration, timeoutUnit);
126 future.cancel(true);
130 Future<T> uninterruptible = Futures.makeUninterruptible(future);
136 future.cancel(true);
|
| /libcore/luni/src/test/java/tests/api/java/util/concurrent/ |
| AbstractExecutorServiceTest.java | 44 Future<?> future = e.submit(task); local
45 future.get();
55 Future<String> future = e.submit(new StringTask()); local
56 String result = future.get();
65 Future<?> future = e.submit(new NoOpRunnable()); local
66 future.get();
67 assertTrue(future.isDone())
75 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| ExecutorsTest.java | 184 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
198 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
212 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
221 * Future.get on submitted tasks will time out if they compute too long.
237 Future future = executor.submit(sleeper); local
239 future.get(SHORT_DELAY_MS, MILLISECONDS);
243 future.cancel(true);
|
| ThreadPoolExecutorSubclassTest.java | 1101 Future<String> future = e.submit(new StringTask()); local
1115 Future<?> future = e.submit(new NoOpRunnable()); local
1129 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| ThreadPoolExecutorTest.java | 970 Future<String> future = e.submit(new StringTask()); local
984 Future<?> future = e.submit(new NoOpRunnable()); local
998 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
[all...] |
| /packages/providers/DownloadProvider/tests/src/tests/http/ |
| MockWebServer.java | 38 import java.util.concurrent.Future;
59 private final Queue<Future<?>> futures = new LinkedList<Future<?>>();
167 Future<?> future = executor.submit(callable); local
168 futures.add(future);
179 Future<?> future = futures.remove(); local
181 future.get(0, TimeUnit.SECONDS);
183 futures.add(future); // still runnin
[all...] |
| /external/bluetooth/bluez/tools/ |
| hciattach_ti.c | 82 uint8_t future[24]; member in struct:bts_header
|
| /external/chromium/base/ |
| message_pump_glib_unittest.cc | 75 base::Time future = last_time + base::TimeDelta::FromMilliseconds(delay_ms); local
76 EventInjector::Event event = { future, task };
|
| /external/skia/src/animator/ |
| SkAnimateActive.cpp | 432 SkMSec future = fAnimators[index]->fStart + state.fStartTime; local
433 if (future > fMaker.fEnableTime)
434 fMaker.notifyInvalTime(future);
439 debugOut.appendS32(future - fMaker.fDebugTimeBase);
|
| /frameworks/base/core/tests/utillib/src/coretestutils/http/ |
| MockWebServer.java | 39 import java.util.concurrent.Future;
63 private final Queue<Future<?>> futures = new LinkedList<Future<?>>();
185 Future<?> future = executor.submit(callable); local
186 futures.add(future);
197 Future<?> future = futures.remove(); local
199 future.get(0, TimeUnit.SECONDS);
201 futures.add(future); // still runnin
[all...] |
| /sdk/ddms/libs/ddmlib/src/com/android/ddmlib/ |
| HandleThread.java | 222 int future; local
224 future = data.getInt();
|
| /frameworks/base/services/java/com/android/server/ |
| DropBoxManagerService.java | 604 // >10sec in the future (due to clock skew), drag them back to avoid
608 EntryFile[] future = null; local
610 future = tail.toArray(new EntryFile[tail.size()]);
618 if (future != null) {
619 for (EntryFile late : future) {
|
| /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...] |
| /libcore/luni/src/test/java/org/apache/harmony/xnet/provider/jsse/ |
| NativeCryptoTest.java | 39 import java.util.concurrent.Future;
553 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener,
558 Future future = executor.submit(new Callable<TestSSLHandshakeCallbacks>() { local
595 return future;
638 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks);
639 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks);
680 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks);
681 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks);
725 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks)
[all...] |
| /prebuilt/common/swing-worker/ |
| swing-worker-1.1.jar | |
| /external/e2fsprogs/lib/blkid/ |
| probe.h | 203 __u32 future; member in struct:cramfs_super_block
|
| /prebuilt/common/ddmlib/ |
| ddmlib-prebuilt.jar | |
| /prebuilt/common/ant/ |
| ant.jar | |
