Searched defs:future (Results 1 - 25 of 67) sorted by relevance

123

/external/testng/src/main/java/org/testng/internal/thread/
H A DFutureResultAdapter.java15 public FutureResultAdapter(Future<?> future) { argument
16 m_future = future;
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/
H A DProducerFactoryTest.java178 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 DProducers.java39 * 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 DProducerMonitor.java37 * <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 DMockFutureListener.java40 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 DAbstractListenableFutureTest.java44 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 DSameThreadScheduledExecutorService.java151 protected ImmediateScheduledFuture(ListenableFuture<V> future) { argument
152 super(future);
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DListenableFutureTester.java35 * 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 DSettableFutureTest.java31 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 DAbstractFutureTest.java48 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 DExecutorTestBase.java45 * 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 DFutureResult.java17 package com.googlecode.android_scripting.future;
/external/libcxx/src/
H A Dfuture.cpp1 //===------------------------- 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()
234 future<voi
[all...]
/external/guava/guava/src/com/google/common/util/concurrent/
H A DAsyncSettableFuture.java24 * 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 DJdkFutureAdapters.java45 * <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 DUninterruptibles.java120 * 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 DGcFinalization.java125 * 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 DShadowAsyncTask.java22 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 Dstreams.rb361 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 DSimpleProducerModule.java54 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 DPeriod.java19 * or future, and as being more or less than the defined value.
126 * Mark the time as being in the future.
144 * Mark the duration as extending into the future if
145 * future is true, and into the past otherwise.
147 * @param future true if the time is in the future
150 public Period inFuture(boolean future) { argument
151 return setFuture(future);
156 * past is true, and into the future otherwise.
203 * duration into the future
297 Period(int limit, boolean future, float count, TimeUnit unit) argument
349 setFuture(boolean future) argument
[all...]
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/duration/
H A DPeriod.java18 * 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
295 Period(int limit, boolean future, float count, TimeUnit unit) argument
347 setFuture(boolean future) argument
[all...]
/external/kernel-headers/original/uapi/linux/
H A Dcramfs_fs.h58 __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 DFutureActivityTask.java17 package com.googlecode.android_scripting.future;
/external/clang/test/SemaCXX/
H A Dlinkage2.cpp61 class future { class in namespace:test6
65 template <class _Rp> future<_Rp>
69 shared_future(future<_Rp&>&& __f);

Completed in 3331 milliseconds

123