| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| 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();
|
| AbstractScheduledServiceTest.java | 27 import java.util.concurrent.Future;
45 volatile ScheduledFuture<?> future = null; field in class:AbstractScheduledServiceTest
55 return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit);
62 assertFalse(future.isDone());
64 assertTrue(future.isCancelled());
82 future.get();
304 Future<?> future = scheduler.schedule(null, Executors.newScheduledThreadPool(10), task); local
312 future.cancel(false);
|
| JSR166TestCase.java | 290 * milliseconds in the future.
560 * Checks that future.get times out, with the default timeout of
563 void assertFutureTimesOut(Future future) {
564 assertFutureTimesOut(future, timeoutMillis());
568 * Checks that future.get times out, with the given millisecond timeout.
570 void assertFutureTimesOut(Future future, long timeoutMillis) {
573 future.get(timeoutMillis, MILLISECONDS);
578 } finally { future.cancel(true);
[all...] |
| /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()) {
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| DownloadService.java | 63 import java.util.concurrent.Future;
72 * processed. It may schedule alarms to resume downloads in future.
127 if (t == null && r instanceof Future<?>) {
129 ((Future<?>) r).get();
255 * Enqueue an {@link #updateLocked()} pass to occur in future.
343 * notifications, and/or schedule future actions with {@link AlarmManager}.
416 // Set alarm when next action is in future. It's okay if the service
|
| /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>() {
|
| OpenSSLHeartbleedTest.java | 45 import java.util.concurrent.Future;
202 Future<Void> serverFuture = mExecutorService.submit(new Callable<Void>() {
210 Future<Void> clientFuture = mExecutorService.submit(new Callable<Void>() {
345 Future<Void> serverToClientTask = mExecutorService.submit(new Callable<Void>() {
[all...] |
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| content_provider.py | 14 from future import Future
140 return Future(callback=
173 # no path associated with this Future.
186 for label, future in futures:
187 try: future.Get()
189 return Future(callback=resolve)
|
| /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...] |
| /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) {
725 * {@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));
|
| /frameworks/testing/support/src/android/support/test/runner/ |
| MonitoringInstrumentation.java | 44 import java.util.concurrent.Future;
265 Future<Activity> startedActivity = mExecutorService.submit(new Callable<Activity>() {
|
| /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
|
| /packages/apps/Gallery2/src/com/android/gallery3d/ui/ |
| AlbumSetSlidingWindow.java | 35 import com.android.gallery3d.util.Future;
430 protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l) {
494 protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l) {
|
| AlbumSlidingWindow.java | 31 import com.android.gallery3d.util.Future;
298 protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l) {
|
| ActionModeHandler.java | 44 import com.android.gallery3d.util.Future;
78 private Future<?> mMenuTask;
|
| MenuExecutor.java | 41 import com.android.gallery3d.util.Future;
61 private Future<?> mTask;
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTest.java | 36 import java.util.concurrent.Future;
368 public Future<byte[]> enqueue(final byte[] sendBytes, final int receiveByteCount)
|
| /packages/apps/Gallery2/src/com/android/gallery3d/app/ |
| ManageCachePage.java | 47 import com.android.gallery3d.util.Future;
85 private Future<Void> mUpdateStorageInfo;
|
| /external/littlemock/tests/com/google/testing/littlemock/ |
| LittleMockTest.java | 70 import java.util.concurrent.Future;
[all...] |
| /external/clang/include/clang/Analysis/Analyses/ |
| ThreadSafetyTIL.h | 304 // Defined after Variable and Future, below.
430 class Future : public SExpr {
440 Future() :
444 virtual ~Future() LLVM_DELETED_FUNCTION;
447 // Registers the location in the AST where this future is stored.
448 // Forcing the future will automatically update the AST.
450 if (Future *F = dyn_cast_or_null<Future>(Member->get()))
454 // A lazy rewriting strategy should subclass Future and override this method.
457 // Return the result of this future if it exists, otherwise return null
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| JSR166TestCase.java | 148 * milliseconds in the future.
441 * Checks that future.get times out, with the default timeout of
444 void assertFutureTimesOut(Future future) {
445 assertFutureTimesOut(future, timeoutMillis());
449 * Checks that future.get times out, with the given millisecond timeout.
451 void assertFutureTimesOut(Future future, long timeoutMillis) {
454 future.get(timeoutMillis, MILLISECONDS);
459 } finally { future.cancel(true);
[all...] |
