/external/guice/extensions/service/src/com/google/inject/service/ |
H A D | Service.java | 20 import java.util.concurrent.Future; 35 * initiated startup. Calling {@link Future#get} will block until the 37 * the service fails to start, {@link Future#get} will throw an {@link 39 * {@link Future#get} returns immediately. 41 Future<State> start(); 49 * initiated shutdown. Calling {@link Future#get} will block until the 52 * already finished stopping, {@link Future#get} returns immediately. 54 Future<State> stop();
|
H A D | CompositeService.java | 30 import java.util.concurrent.Future; 80 public Future<State> start() { 81 final List<Future<State>> tasks = Lists.newArrayList(); 89 public Future<State> stop() { 90 final List<Future<State>> tasks = Lists.newArrayList(); 104 private FutureTask<Service.State> futureGet(final List<Future<Service.State>> tasks, 109 for (Future<Service.State> task : tasks) {
|
H A D | AsyncService.java | 23 import java.util.concurrent.Future; 45 public synchronized final Future<State> start() { 71 public synchronized final Future<State> stop() {
|
/external/testng/src/main/java/org/testng/internal/thread/ |
H A D | FutureResultAdapter.java | 5 import java.util.concurrent.Future; 8 * A very reduced interface of <code>Future</code>. 13 Future<?> m_future; 15 public FutureResultAdapter(Future<?> future) {
|
/external/glide/library/src/main/java/com/bumptech/glide/request/ |
H A D | FutureTarget.java | 5 import java.util.concurrent.Future; 9 * {@link java.util.concurrent.Future}. For example: 29 public interface FutureTarget<R> extends Future<R>, Target<R> {
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AsyncFunction.java | 19 import java.util.concurrent.Future; 30 * Returns an output {@code Future} to use in place of the given {@code 31 * input}. The output {@code Future} need not be {@linkplain Future#isDone 35 * failing {@code Future}.
|
H A D | ListenableFuture.java | 21 import java.util.concurrent.Future; 26 * A {@link Future} that accepts completion listeners. Each listener has an 28 * computation is {@linkplain Future#isDone() complete}. If the computation has 39 * derived {@code Future}, as in {@link Futures#allAsList(Iterable) 45 * access to the {@code Future} result. (Users who want such access may prefer 65 * depends on how they currently create {@code Future} instances: 77 * <p>Occasionally, an API will return a plain {@code Future} and it will be 86 public interface ListenableFuture<V> extends Future<V> { 89 * the given executor. The listener will run when the {@code Future}'s 90 * computation is {@linkplain Future#isDon [all...] |
H A D | ForwardingFuture.java | 23 import java.util.concurrent.Future; 28 * A {@link Future} which forwards all its method calls to another future. 39 implements Future<V> { 44 @Override protected abstract Future<V> delegate(); 78 * can pass in an already constructed {@link Future} as the delegate. 84 private final Future<V> delegate; 86 protected SimpleForwardingFuture(Future<V> delegate) { 91 protected final Future<V> delegate() {
|
H A D | 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 49 * until the future is {@linkplain Future#isDone() done}. 55 * Future} instances to be upgraded to {@code ListenableFuture} after the 59 Future<V> future) { 67 * Submits a blocking task for the given {@link Future} to provide {@link 76 * is {@linkplain Future#isDone() done}, so each call to this method may 85 * Future} instances to be upgraded to {@code ListenableFuture} after the 91 Future< [all...] |
H A D | ListeningExecutorService.java | 23 import java.util.concurrent.Future; 74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 95 <T> List<Future<T>> invokeAll(
|
H A D | FutureCallback.java | 20 import java.util.concurrent.Future; 25 * A callback for accepting the results of a {@link java.util.concurrent.Future} 35 * Invoked with the result of the {@code Future} computation when it is 41 * Invoked when a {@code Future} computation fails or is canceled. 43 * <p>If the future's {@link Future#get() get} method throws an {@link
|
H A D | FutureFallback.java | 22 import java.util.concurrent.Future; 25 * Provides a backup {@code Future} to replace an earlier failed {@code Future}. 26 * An implementation of this interface can be applied to an input {@code Future} 29 * @param <V> the result type of the provided backup {@code Future} 37 * Returns a {@code Future} to be used in place of the {@code Future} that 43 * Future#get() get} method throws an {@link ExecutionException}, then the
|
H A D | ForwardingExecutorService.java | 26 import java.util.concurrent.Future; 54 public <T> List<Future<T>> invokeAll( 60 public <T> List<Future<T>> invokeAll( 104 public <T> Future<T> submit(Callable<T> task) { 109 public Future<?> submit(Runnable task) { 114 public <T> Future<T> submit(Runnable task, T result) {
|
/external/llvm/lib/Support/ |
H A D | ThreadPool.cpp | 88 auto Future = PackagedTask.get_future(); local 99 return Future.share(); 141 // Get a Future with launch::deferred execution using std::async 142 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); 145 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); 147 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); 148 PackagedTaskTy PackagedTask([Future](bool) -> bool { Future.get(); return false; }); 151 return Future; [all...] |
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
H A D | ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); 30 <T> Future<T> submit(Runnable task, T result); 32 Future<?> submit(Runnable task); 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 37 <T> List<Future<T>> invokeAll(
|
H A D | AbstractExecutorService.java | 17 public Future<?> submit(Runnable task) { 24 public <T> Future<T> submit(Runnable task, T result) { 31 public <T> Future<T> submit(Callable<T> task) { 46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); 60 Future<T> f = ecs.poll(); 99 for (Future<T> f : futures) 120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 124 List<Future<T>> futures = new ArrayList<Future< [all...] |
/external/python/cpython3/Lib/concurrent/futures/ |
H A D | __init__.py | 13 Future,
|
/external/python/futures/concurrent/futures/ |
H A D | __init__.py | 13 Future,
|
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
H A D | RobolectricBackgroundExecutorService.java | 10 import java.util.concurrent.Future; 42 public <T> Future<T> submit(Callable<T> tCallable) { 47 public <T> Future<T> submit(Runnable runnable, T t) { 52 public Future<?> submit(Runnable runnable) { 56 private <T> Future<T> schedule(final FutureTask<T> futureTask) { 68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException { 73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
|
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
H A D | ExecutorTestBase.java | 19 import java.util.concurrent.Future; 51 protected void assertBlocks(final Future<?> future) throws Exception {
|
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
H A D | RoboExecutorService.java | 10 import java.util.concurrent.Future; 85 public <T> Future<T> submit(Callable<T> tCallable) { 90 public <T> Future<T> submit(Runnable runnable, T t) { 95 public Future<?> submit(Runnable runnable) { 99 private <T> Future<T> schedule(final FutureTask<T> futureTask) { 114 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException { 119 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException { 136 Future<?> possiblyIgnoredError = submit(runnable);
|
/external/sl4a/Utils/src/com/googlecode/android_scripting/future/ |
H A D | FutureResult.java | 20 import java.util.concurrent.Future; 27 public class FutureResult<T> implements Future<T> {
|
/external/clang/test/SemaCXX/ |
H A D | decltype.cpp | 20 struct Future { struct 21 explicit Future(T v); 36 Future<int> f1(42); 37 f1.call([](int){ return Future<float>(0); });
|
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
H A D | TestingExecutorsTest.java | 29 import java.util.concurrent.Future; 73 List<Future<Boolean>> futureList = executor.invokeAll( 75 Future<Boolean> future = futureList.get(0); 94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule( 107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
|
/external/python/cpython3/Lib/test/test_asyncio/ |
H A D | test_sslproto.py | 49 waiter = asyncio.Future(loop=self.loop) 51 handshake_fut = asyncio.Future(loop=self.loop) 66 waiter = asyncio.Future(loop=self.loop) 77 waiter = asyncio.Future(loop=self.loop) 91 waiter = asyncio.Future(loop=self.loop)
|