Searched refs:Future (Results 1 - 25 of 137) sorted by relevance

123456

/external/guice/extensions/service/src/com/google/inject/service/
H A DService.java20 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 DCompositeService.java30 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 DAsyncService.java23 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 DFutureResultAdapter.java5 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 DFutureTarget.java5 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 DAsyncFunction.java19 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 DListenableFuture.java21 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 DForwardingFuture.java23 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 DJdkFutureAdapters.java26 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 DListeningExecutorService.java23 import java.util.concurrent.Future;
74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
95 <T> List<Future<T>> invokeAll(
H A DFutureCallback.java20 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 DFutureFallback.java22 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 DForwardingExecutorService.java26 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 DThreadPool.cpp88 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 DExecutorService.java28 <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 DAbstractExecutorService.java17 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__.py13 Future,
/external/python/futures/concurrent/futures/
H A D__init__.py13 Future,
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/
H A DRobolectricBackgroundExecutorService.java10 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 DExecutorTestBase.java19 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 DRoboExecutorService.java10 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 DFutureResult.java20 import java.util.concurrent.Future;
27 public class FutureResult<T> implements Future<T> {
/external/clang/test/SemaCXX/
H A Ddecltype.cpp20 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 DTestingExecutorsTest.java29 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 Dtest_sslproto.py49 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)

Completed in 417 milliseconds

123456