| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenableFutureTester.java | 32 * Used to test listenable future implementations.
39 private final ListenableFuture<?> future; field in class:ListenableFutureTester
42 public ListenableFutureTester(ListenableFuture<?> future) {
44 this.future = future;
49 future.addListener(new Runnable() {
56 assertFalse(future.isDone());
57 assertFalse(future.isCancelled());
66 assertTrue(future.isDone());
67 assertFalse(future.isCancelled())
[all...] |
| AbstractFutureTest.java | 47 AbstractFuture<String> future = new AbstractFuture<String>() { local
53 ExecutionException ee1 = getExpectingExecutionException(future);
54 ExecutionException ee2 = getExpectingExecutionException(future);
67 InterruptibleFuture future = new InterruptibleFuture(); local
68 assertTrue(future.cancel(false));
69 assertTrue(future.isCancelled());
70 assertTrue(future.isDone());
71 assertFalse(future.wasInterrupted);
75 InterruptibleFuture future = new InterruptibleFuture(); local
76 assertTrue(future.cancel(true))
83 AbstractFuture<String> future = new AbstractFuture<String>() { local
96 final AbstractFuture<String> future = new AbstractFuture<String>() {}; local
[all...] |
| SettableFutureTest.java | 31 private SettableFuture<String> future; field in class:SettableFutureTest
38 future = SettableFuture.create();
39 tester = new ListenableFutureTester(future);
45 future.get(5, TimeUnit.MILLISECONDS);
51 assertTrue(future.set("value"));
56 assertTrue(future.setException(new Exception("failure")));
62 future.setException(null);
66 assertFalse(future.isDone());
67 assertTrue(future.setException(new Exception("failure")));
72 assertTrue(future.cancel(true))
[all...] |
| MoreExecutorsTest.java | 35 import java.util.concurrent.Future;
72 Future<?> future = executor.submit(incrementTask);
73 assertTrue(future.isDone());
83 ListenableFuture<?> future = executor.submit(incrementTask); local
84 assertTrue(future.isDone());
85 assertListenerRunImmediately(future);
113 List<Future<Integer>> futures =
117 Future<Integer> future = futures.get(i) local
[all...] |
| 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...] |
| /frameworks/base/core/java/android/accounts/ |
| AccountManagerCallback.java | 19 void run(AccountManagerFuture<V> future);
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| FutureListener.java | 20 public void onFutureDone(Future<T> future);
|
| JobLimiter.java | 41 private static class JobWrapper<T> implements Future<T>, Job<T> {
44 private Future<T> mDelegate;
53 public synchronized void setFuture(Future<T> future) {
55 mDelegate = future;
136 public synchronized <T> Future<T> submit(Job<T> job, FutureListener<T> listener) {
137 JobWrapper<T> future = new JobWrapper<T>(Utils.checkNotNull(job), listener); local
138 mJobs.addLast(future);
140 return future;
155 public synchronized void onFutureDone(Future future)
[all...] |
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| AbstractCheckedFutureTest.java | 70 final CheckedFuture<Boolean, ?> future = local
73 assertFalse(future.isDone());
74 assertFalse(future.isCancelled());
79 future.cancel(true);
84 future.checkedGet();
90 assertTrue(future.isDone());
91 assertTrue(future.isCancelled());
97 final CheckedFuture<Boolean, ?> future = local
103 assertFalse(future.isDone());
104 assertFalse(future.isCancelled())
134 final CheckedFuture<Boolean, ?> future = local
[all...] |
| 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...] |
| MockFutureListener.java | 39 private final ListenableFuture<?> future; field in class:MockFutureListener
41 public MockFutureListener(ListenableFuture<?> future) {
43 this.future = future;
45 future.addListener(this, MoreExecutors.sameThreadExecutor());
55 * Asserts that the future returns the expected data.
64 Assert.assertEquals(expectedData, future.get());
72 * Asserts that the future throws an {@code ExecutableException} and that the
80 future.get();
|
| /frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
| RealMediaPlayerTest.java | 40 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable); local
41 getInstrumentation().runOnMainSync(future);
42 return DynamicProxy.dynamicProxy(MediaPlayerProxy.class, future.get(1, TimeUnit.SECONDS));
|
| /external/guava/guava-tests/test/com/google/common/testing/ |
| GcFinalizationTest.java | 39 final SettableFuture<Void> future = SettableFuture.create(); local
41 protected void finalize() { future.set(null); }
44 GcFinalization.awaitDone(future);
45 assertTrue(future.isDone());
46 assertFalse(future.isCancelled());
50 final SettableFuture<Void> future = SettableFuture.create(); local
52 protected void finalize() { future.cancel(false); }
55 GcFinalization.awaitDone(future);
56 assertTrue(future.isDone());
57 assertTrue(future.isCancelled())
130 final SettableFuture<Void> future = SettableFuture.create(); local
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| JdkFutureAdapters.java | 26 import java.util.concurrent.Future;
32 * Future} instances. Note that, whenver possible, it is strongly preferred to
42 * Assigns a thread to the given {@link Future} to provide {@link
45 * <p><b>Warning:</b> If the input future does not already implement {@link
46 * ListenableFuture}, the returned future will emulate {@link
49 * until the future is {@linkplain Future#isDone() done}.
55 * Future} instances to be upgraded to {@code ListenableFuture} after the
59 Future<V> future) {
[all...] |
| 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...] |
| /device/google/accessory/demokit/app/ |
| Android.mk | 26 LOCAL_JAVA_LIBRARIES := com.android.future.usb.accessory
|
| /frameworks/base/libs/usb/ |
| Android.mk | 25 LOCAL_MODULE:= com.android.future.usb.accessory
|
| /frameworks/support/volley/src/com/android/volley/toolbox/ |
| AndroidAuthenticator.java | 59 AccountManagerFuture<Bundle> future = accountManager.getAuthToken(mAccount, local
63 result = future.getResult();
68 if (future.isDone() && !future.isCancelled()) {
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/ |
| NetworkPolicyManagerServiceTest.java | 94 import java.util.concurrent.Future;
271 final Future<Intent> backgroundChanged = mServiceContext.nextBroadcastIntent(
327 Future<Void> future; local
328 Future<Void> futureGuest;
332 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL);
335 future.get();
343 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL);
347 future.get();
355 future = expectRulesChanged(UID_A, RULE_REJECT_METERED)
373 Future<Void> future; local
408 Future<Void> future; local
444 Future<Void> future; local
604 Future<Void> future; local
654 Future<Void> future; local
689 Future<Void> future; local
820 Future<Void> future; local
889 final FutureAnswer future = new FutureAnswer(); local
934 final FutureAnswer future = new FutureAnswer(); local
941 final FutureAnswer future = new FutureAnswer(); local
948 final FutureAnswer future = new FutureAnswer(); local
1009 final IdleFuture future = new IdleFuture(); local
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/ui/ |
| BitmapLoader.java | 21 import com.android.gallery3d.util.Future;
44 private Future<Bitmap> mTask;
48 public void onFutureDone(Future<Bitmap> future) {
51 mBitmap = future.get();
59 if (future.isCancelled() && mBitmap == null) {
105 abstract protected Future<Bitmap> submitBitmapTask(FutureListener<Bitmap> l);
|
| /external/zxing/qr_scanner/src/com/google/zxing/client/android/ |
| InactivityTimer.java | 75 ScheduledFuture<?> future = inactivityFuture; local
76 if (future != null) {
77 future.cancel(true);
|
| /external/clang/INPUTS/ |
| all-std-headers.cpp | 66 #if __has_include(<future>)
67 #include <future>
|
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| GcFinalization.java | 27 import java.util.concurrent.Future;
110 * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage
115 public static void awaitDone(Future<?> future) {
116 if (future.isDone()) {
123 if (future.isDone()) {
128 future.get(1L, SECONDS);
135 throw new RuntimeException("Unexpected interrupt while waiting for future", ie);
141 String.format("Future not done within %d second timeout", timeoutSeconds))
[all...] |
| /prebuilts/gcc/linux-x86/host/i686-linux-glibc2.7-4.4.3/i686-linux/include/c++/4.4.3/backward/ |
| backward_warning.h | 30 may be removed without further notice at a future date. Please use a \
|
| /prebuilts/gcc/linux-x86/host/i686-linux-glibc2.7-4.6/i686-linux/include/c++/4.6.x-google/backward/ |
| backward_warning.h | 35 may be removed without further notice at a future date. Please use a \
|
