/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | AbstractFutureTest.java | 47 AbstractFuture<String> future = new AbstractFuture<String>() { in testException() local 67 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneNoInterrupt() local 75 InterruptibleFuture future = new InterruptibleFuture(); in testCancel_notDoneInterrupt() local 83 AbstractFuture<String> future = new AbstractFuture<String>() { in testCancel_done() local 96 final AbstractFuture<String> future = new AbstractFuture<String>() {}; in testCompletionFinishesWithDone() local 166 AbstractFuture<String> future) throws InterruptedException { in getExpectingExecutionException()
|
D | FuturesTest.java | 96 ListenableFuture<String> future = Futures.immediateFuture(DATA1); in testImmediateFuture() local 113 ListenableFuture<String> future = in testImmediateFailedFuture() local 128 CheckedFuture<String, MyException> future = Futures.immediateCheckedFuture( in testImmediateCheckedFuture() local 151 CheckedFuture<String, MyException> future = in testImmediateFailedCheckedFuture() local 186 ListenableFuture<FooChild> future = Futures.immediateFuture(null); in testTransform_ListenableFuture_genericsHierarchy() local
|
D | ListenableFutureTester.java | 39 private final ListenableFuture<?> future; field in ListenableFutureTester 42 public ListenableFutureTester(ListenableFuture<?> future) { in ListenableFutureTester()
|
D | MoreExecutorsTest.java | 83 ListenableFuture<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution() local 117 Future<Integer> future = futures.get(i); in testSameThreadExecutorInvokeAll() local 225 private static void assertListenerRunImmediately(ListenableFuture<?> future) { in assertListenerRunImmediately()
|
D | SettableFutureTest.java | 31 private SettableFuture<String> future; field in SettableFutureTest
|
D | AbstractListeningExecutorServiceTest.java | 61 Future<?> future = e.submit(task); in testExecuteRunnable() local 71 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local 81 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local 91 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2() local
|
D | AbstractScheduledServiceTest.java | 45 volatile ScheduledFuture<?> future = null; field in AbstractScheduledServiceTest 304 Future<?> future = scheduler.schedule(null, Executors.newScheduledThreadPool(10), task); in testCustomSchedule_startStop() local
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
D | Futures.java | 80 ListenableFuture<V> future, Function<Exception, X> mapper) { in makeChecked() 91 SettableFuture<V> future = SettableFuture.create(); in immediateFuture() local 106 SettableFuture<V> future = SettableFuture.create(); in immediateCheckedFuture() local
|
D | JdkFutureAdapters.java | 59 Future<V> future) { in listenInPoolThread() 68 Future<V> future, Executor executor) { in listenInPoolThread()
|
D | Uninterruptibles.java | 126 public static <V> V getUninterruptibly(Future<V> future) in getUninterruptibly() 154 Future<V> future, long timeout, TimeUnit unit) in getUninterruptibly()
|
D | SimpleTimeLimiter.java | 126 Future<T> future = executor.submit(callable); in callWithTimeout() local
|
/external/robolectric/src/test/java/com/xtremelabs/robolectric/shadows/ |
D | AccountManagerTest.java | 45 AccountManagerFuture<Bundle> future = in testGetAuthTokenByFeatures_isCancelled() local 55 AccountManagerFuture<Bundle> future = in testGetAuthTokenByFeatures_isDoneWithCancel() local 65 AccountManagerFuture<Bundle> future = in testGetAuthTokenByFeatures_isDoneWithGetResult() local 81 AccountManagerFuture<Bundle> future = in testGetAuthTokenByFeatures_getResult() local 92 AccountManagerFuture<Bundle> future = in testGetAuthToken_getResult() local
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
D | AbstractCheckedFutureTest.java | 70 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnCancellation() local 97 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnInterruption() local 134 final CheckedFuture<Boolean, ?> future = in testCheckedGetThrowsApplicationExceptionOnError() local
|
D | MockFutureListener.java | 39 private final ListenableFuture<?> future; field in MockFutureListener 41 public MockFutureListener(ListenableFuture<?> future) { in MockFutureListener()
|
D | AbstractListenableFutureTest.java | 44 protected ListenableFuture<Boolean> future; field in AbstractListenableFutureTest
|
/external/robolectric/src/test/java/com/xtremelabs/robolectric/util/ |
D | RobolectricBackgroundExecutorServiceTest.java | 47 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread() local 61 Future<String> future = executorService.submit(new Callable<String>() { in submitCallable_shouldRunStuffOnBackgroundThread() local
|
/external/guava/guava-tests/test/com/google/common/testing/ |
D | GcFinalizationTest.java | 39 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future() local 50 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Cancel() local 130 final SettableFuture<Void> future = SettableFuture.create(); in testAwaitDone_Future_Interrupted_Interrupted() local
|
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
D | ShadowAsyncTask.java | 22 private final FutureTask<Result> future; field in ShadowAsyncTask
|
/external/zxing/qr_scanner/src/com/google/zxing/client/android/ |
D | InactivityTimer.java | 75 ScheduledFuture<?> future = inactivityFuture; in cancel() local
|
/external/guava/guava-testlib/src/com/google/common/testing/ |
D | GcFinalization.java | 115 public static void awaitDone(Future<?> future) { in awaitDone()
|
/external/clang/test/SemaCXX/ |
D | linkage2.cpp | 59 class future { class
|
/external/smack/src/org/jivesoftware/smackx/filetransfer/ |
D | FaultTolerantNegotiator.java | 94 Future<InputStream> future; in createIncomingStream() local
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
D | WriterTesterTest.java | 105 private Future<char[]> future; field in WriterTesterTest.PipedWriterCharSinkTester
|
D | OutputStreamTesterTest.java | 116 private Future<byte[]> future; field in OutputStreamTesterTest.PipedOutputStreamSinkTester
|
/external/chromium/chrome/browser/safe_browsing/ |
D | protocol_manager_unittest.cc | 115 Time future = now + TimeDelta::FromMinutes(1); in TEST_F() local
|