/external/libgdx/gdx/src/com/badlogic/gdx/utils/async/ |
H A D | AsyncResult.java | 27 private final Future<T> future;
field in class:AsyncResult 29 AsyncResult (Future<T> future) {
argument 30 this.future = future;
35 return future.isDone();
42 return future.get();
|
/external/testng/src/main/java/org/testng/internal/thread/ |
H A D | FutureResultAdapter.java | 15 public FutureResultAdapter(Future<?> future) { argument 16 m_future = future;
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
H A D | ProducerFactoryTest.java | 178 private static <T> Producer<T> producerOfFuture(final ListenableFuture<T> future) { argument 181 return future;
|
/external/dagger2/producers/src/main/java/dagger/producers/internal/ |
H A D | Producers.java | 39 * Returns a future of {@link Produced} that represents the completion (either success or failure) 40 * of the given future. If the input future succeeds, then the resulting future also succeeds with 41 * a successful {@code Produced}; if the input future fails, then the resulting future succeeds 44 * <p>Cancelling the resulting future will propagate the cancellation to the input future; but 45 * cancelling the input future will trigger the resulting future t 50 createFutureProduced(ListenableFuture<T> future) argument 82 createFutureSingletonSet(ListenableFuture<T> future) argument [all...] |
/external/dagger2/producers/src/main/java/dagger/producers/monitoring/ |
H A D | ProducerMonitor.java | 37 * <li>If the method returns a future, then: 39 * <li>{@link #succeeded(Object)} if the method returned normally, and the future succeeded; or 41 * future failed. 72 * Called when the producer’s future has completed successfully with a value. 80 * Called when the producer's future has failed with an exception. 88 * Adds this monitor's completion methods as a callback to the future. This is only intended to be 91 public <T> void addCallbackTo(ListenableFuture<T> future) { argument 93 future,
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
H A D | MockFutureListener.java | 40 private final ListenableFuture<?> future; field in class:MockFutureListener 42 public MockFutureListener(ListenableFuture<?> future) { argument 44 this.future = future; 46 future.addListener(this, directExecutor()); 56 * Asserts that the future returns the expected data. 65 Assert.assertEquals(expectedData, future.get()); 73 * Asserts that the future throws an {@code ExecutableException} and that the 81 future.get();
|
H A D | AbstractListenableFutureTest.java | 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 74 assertFalse(future.isDone()); 75 assertFalse(future.isCancelled()); 80 // Wait on the future in a separate thread. 85 assertSame(Boolean.TRUE, future.get()); 93 // Release the future value. 102 assertTrue(future [all...] |
H A D | SameThreadScheduledExecutorService.java | 151 protected ImmediateScheduledFuture(ListenableFuture<V> future) { argument 152 super(future);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | ListenableFutureTester.java | 35 * Used to test listenable future implementations. 42 private final ListenableFuture<?> future; field in class:ListenableFutureTester 45 public ListenableFutureTester(ListenableFuture<?> future) { argument 47 this.future = checkNotNull(future); 52 future.addListener(new Runnable() { 59 assertFalse(future.isDone()); 60 assertFalse(future.isCancelled()); 69 assertTrue(future.isDone()); 70 assertFalse(future [all...] |
H A D | 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 [all...] |
H A D | AbstractFutureTest.java | 48 AbstractFuture<String> future = new AbstractFuture<String>() { 54 ExecutionException ee1 = getExpectingExecutionException(future); 55 ExecutionException ee2 = getExpectingExecutionException(future); 68 InterruptibleFuture future = new InterruptibleFuture(); 69 assertTrue(future.cancel(false)); 70 assertTrue(future.isCancelled()); 71 assertTrue(future.isDone()); 72 assertFalse(future.wasInterrupted()); 73 assertFalse(future.interruptTaskWasCalled); 75 future 180 getExpectingExecutionException( AbstractFuture<String> future) argument [all...] |
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
H A D | ExecutorTestBase.java | 45 * Asserts that the given future blocks. 47 * @param future 48 * future to test 51 protected void assertBlocks(final Future<?> future) throws Exception { argument 53 future.get(10, TimeUnit.MILLISECONDS);
|
/external/sl4a/Utils/src/com/googlecode/android_scripting/future/ |
H A D | FutureResult.java | 17 package com.googlecode.android_scripting.future;
|
/external/libcxx/src/ |
H A D | future.cpp | 1 //===------------------------- future.cpp ---------------------------------===// 14 #include "future" 30 return "future"; 51 return string("The future has already been retrieved from " 189 future<void>::future(__assoc_sub_state* __state) function in class:future 200 future<void>::~future() 207 future<void>::get() 232 future<voi [all...] |
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AsyncSettableFuture.java | 24 * A settable future that can be set asynchronously via {@link #setFuture}. 26 * future that sets a normal settable future after the delegate is complete. 30 * as improved cancellation semantics (i.e. if either future is cancelled, 39 /** Creates a new asynchronously-settable future. */ 54 * Sets this future to forward to the given future. Returns {@code true} 55 * if the future was able to be set (i.e. it hasn't been set already). 57 public boolean setFuture(ListenableFuture<? extends V> future) { argument 58 return nested.setFuture(checkNotNull(future)); [all...] |
H A D | JdkFutureAdapters.java | 45 * <p><b>Warning:</b> If the input future does not already implement {@code 46 * ListenableFuture}, the returned future will emulate {@link 49 * until the future is {@linkplain Future#isDone() done}. 59 Future<V> future) { 60 if (future instanceof ListenableFuture) { 61 return (ListenableFuture<V>) future; 63 return new ListenableFutureAdapter<V>(future); 70 * <p><b>Warning:</b> If the input future does not already implement {@code 71 * ListenableFuture}, the returned future will emulate {@link 75 * to work. The task's execution consists of blocking until the input future 58 listenInPoolThread( Future<V> future) argument 90 listenInPoolThread( Future<V> future, Executor executor) argument [all...] |
H A D | Uninterruptibles.java | 120 * Invokes {@code future.}{@link Future#get() get()} uninterruptibly. 131 public static <V> V getUninterruptibly(Future<V> future) argument 137 return future.get(); 151 * {@code future.}{@link Future#get(long, TimeUnit) get(timeout, unit)} 163 Future<V> future, long timeout, TimeUnit unit) 173 return future.get(remainingNanos, NANOSECONDS); 162 getUninterruptibly( Future<V> future, long timeout, TimeUnit unit) argument
|
/external/guava/guava-testlib/src/com/google/common/testing/ |
H A D | GcFinalization.java | 125 * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage 130 public static void awaitDone(Future<?> future) { argument 131 if (future.isDone()) { 138 if (future.isDone()) { 143 future.get(1L, SECONDS); 150 throw new RuntimeException("Unexpected interrupt while waiting for future", ie);
|
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
H A D | ShadowAsyncTask.java | 22 private final FutureTask<Result> future; field in class:ShadowAsyncTask 28 future = new FutureTask<Result>(worker) { 57 return future.isCancelled(); 62 return future.cancel(mayInterruptIfRunning); 67 return future.get(); 72 return future.get(timeout, unit); 84 future.run();
|
/external/antlr/antlr-3.4/runtime/Ruby/lib/antlr3/ |
H A D | streams.rb | 361 non-ASCII encoding. However, encoding-savvy recognition code is a future 904 @position = future?( 2 ) || @tokens.length 933 index = future?( k ) or return nil 946 def future?( k = 1 )
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/ |
H A D | SimpleProducerModule.java | 54 static ListenableFuture<String> settableFutureStr(SettableFuture<String> future) { argument 55 return future; 67 return Futures.immediateFuture("future str"); 79 return Futures.immediateFuture("future str with arg"); 91 return Futures.immediateFuture("future str throwing exception"); 103 return Futures.immediateFuture("future str with arg throwing exception"); 123 return Futures.immediateFuture("future str with args");
|
/external/icu/android_icu4j/src/main/java/android/icu/impl/duration/ |
H A D | Period.java | 17 * or future, and as being more or less than the defined value. 124 * Mark the time as being in the future. 142 * Mark the duration as extending into the future if 143 * future is true, and into the past otherwise. 145 * @param future true if the time is in the future 148 public Period inFuture(boolean future) { argument 149 return setFuture(future); 154 * past is true, and into the future otherwise. 201 * duration into the future 293 Period(int limit, boolean future, float count, TimeUnit unit) argument 345 setFuture(boolean future) argument [all...] |
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/duration/ |
H A D | Period.java | 16 * or future, and as being more or less than the defined value. 122 * Mark the time as being in the future. 140 * Mark the duration as extending into the future if 141 * future is true, and into the past otherwise. 143 * @param future true if the time is in the future 146 public Period inFuture(boolean future) { argument 147 return setFuture(future); 152 * past is true, and into the future otherwise. 199 * duration into the future 291 Period(int limit, boolean future, float count, TimeUnit unit) argument 343 setFuture(boolean future) argument [all...] |
/external/kernel-headers/original/uapi/linux/ |
H A D | cramfs_fs.h | 58 __u32 future; /* reserved for future use */ member in struct:cramfs_super 80 * changed to test super.future instead.
|
/external/sl4a/Common/src/com/googlecode/android_scripting/future/ |
H A D | FutureActivityTask.java | 17 package com.googlecode.android_scripting.future;
|