| /external/python/cpython3/Doc/library/ |
| D | asyncio-future.rst | 10 *Future* objects are used to bridge **low-level callback-based code**
14 Future Functions
21 * an instance of :class:`asyncio.Future`,
23 * a Future-like object with a ``_asyncio_future_blocking``
33 * *obj* argument as is, if *obj* is a :class:`Future`,
34 a :class:`Task`, or a Future-like object (:func:`isfuture`
56 Wrap a :class:`concurrent.futures.Future` object in a
57 :class:`asyncio.Future` object.
60 Future Object
63 .. class:: Future(\*, loop=None)
[all …]
|
| D | concurrent.futures.rst | 34 and returns a :class:`Future` object representing the execution of the
104 Deadlocks can occur when the callable associated with a :class:`Future` waits on
105 the results of another :class:`Future`. For example::
209 Calling :class:`Executor` or :class:`Future` methods from a callable submitted
278 Future Objects
281 The :class:`Future` class encapsulates the asynchronous execution of a callable.
282 :class:`Future` instances are created by :meth:`Executor.submit`.
284 .. class:: Future
286 Encapsulates the asynchronous execution of a callable. :class:`Future`
353 The following :class:`Future` methods are meant for use in unit tests and
[all …]
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | AbstractExecutorService.java | 17 public Future<?> submit(Runnable task) { in submit()
24 public <T> Future<T> submit(Runnable task, T result) { in submit()
31 public <T> Future<T> submit(Callable<T> task) { in submit()
46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny()
60 Future<T> f = ecs.poll(); in doInvokeAny()
99 for (Future<T> f : futures) in doInvokeAny()
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
132 for (Future<T> f : futures) { in invokeAll()
145 for (Future<T> f : futures) in invokeAll()
[all …]
|
| D | ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); in submit()
30 <T> Future<T> submit(Runnable task, T result); in submit()
32 Future<?> submit(Runnable task); in submit()
34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
37 <T> List<Future<T>> invokeAll( in invokeAll()
|
| /external/llvm/lib/Support/ |
| D | ThreadPool.cpp | 88 auto Future = PackagedTask.get_future(); in asyncImpl() local
99 return Future.share(); in asyncImpl()
142 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl() local
145 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); in asyncImpl()
147 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); in asyncImpl()
148 PackagedTaskTy PackagedTask([Future](bool) -> bool { Future.get(); return false; }); in asyncImpl()
151 return Future; in asyncImpl()
|
| /external/python/futures/docs/ |
| D | index.rst | 25 returns a :class:`Future` representing the execution of the callable.
79 Deadlock can occur when the callable associated with a :class:`Future` waits on
80 the results of another :class:`Future`. For example:
156 Calling :class:`Executor` or :class:`Future` methods from a callable submitted
199 Future Objects
202 The :class:`Future` class encapulates the asynchronous execution of a callable.
203 :class:`Future` instances are created by :meth:`Executor.submit`.
205 .. method:: Future.cancel()
211 .. method:: Future.cancelled()
215 .. method:: Future.running()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingFuture.java | 23 import java.util.concurrent.Future;
39 implements Future<V> {
44 @Override protected abstract Future<V> delegate(); in delegate()
84 private final Future<V> delegate;
86 protected SimpleForwardingFuture(Future<V> delegate) { in SimpleForwardingFuture()
91 protected final Future<V> delegate() { in delegate()
|
| D | JdkFutureAdapters.java | 26 import java.util.concurrent.Future;
59 Future<V> future) { in listenInPoolThread()
91 Future<V> future, Executor executor) { in listenInPoolThread()
130 private final Future<V> delegate;
132 ListenableFutureAdapter(Future<V> delegate) { in ListenableFutureAdapter()
136 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
142 protected Future<V> delegate() { in delegate()
|
| D | ForwardingExecutorService.java | 26 import java.util.concurrent.Future;
54 public <T> List<Future<T>> invokeAll( in invokeAll()
60 public <T> List<Future<T>> invokeAll( in invokeAll()
104 public <T> Future<T> submit(Callable<T> task) { in submit()
109 public Future<?> submit(Runnable task) { in submit()
114 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| D | WrappingExecutorService.java | 30 import java.util.concurrent.Future;
99 public final <T> Future<T> submit(Callable<T> task) {
104 public final Future<?> submit(Runnable task) {
109 public final <T> Future<T> submit(Runnable task, T result) {
114 public final <T> List<Future<T>> invokeAll(
120 public final <T> List<Future<T>> invokeAll(
|
| D | AbstractScheduledService.java | 29 import java.util.concurrent.Future;
125 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedDelaySchedule()
144 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedRateSchedule()
152 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
163 private volatile Future<?> runningTask;
426 private Future<Void> currentFuture;
482 protected Future<Void> delegate() {
488 final Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 10 import java.util.concurrent.Future;
85 public <T> Future<T> submit(Callable<T> tCallable) { in submit()
90 public <T> Future<T> submit(Runnable runnable, T t) { in submit()
95 public Future<?> submit(Runnable runnable) { in submit()
99 private <T> Future<T> schedule(final FutureTask<T> futureTask) { in schedule()
114 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws Interrupt… in invokeAll()
119 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit… in invokeAll()
136 Future<?> possiblyIgnoredError = submit(runnable); in execute()
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| D | CompositeService.java | 29 import java.util.concurrent.Future;
82 public Future<State> start() { in compose()
83 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
92 public Future<State> stop() { in compose()
93 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
109 final List<Future<Service.State>> tasks, final Service.State state) {
115 for (Future<Service.State> task : tasks) {
|
| D | Service.java | 20 import java.util.concurrent.Future;
40 Future<State> start(); in start()
51 Future<State> stop(); in stop()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 35 import java.util.concurrent.Future;
74 Future<?> f = testExecutor.submit(doNothing()); in testSubmit()
81 Future<String> f = testExecutor.submit(doNothing(), RESULT_VALUE); in testSubmit()
89 Future<String> f = testExecutor.submit(task); in testSubmit()
100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
135 private static void checkResults(List<Future<String>> futures) in checkResults()
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
221 public <T> List<Future<T>> invokeAll( in invokeAll()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
[all …]
|
| /external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/ |
| D | ThreadPool.cpp | 85 auto Future = PackagedTask.get_future(); in asyncImpl() local
96 return Future.share(); in asyncImpl()
134 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl() local
137 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); in asyncImpl()
139 return Future; in asyncImpl()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | NativeCryptoTest.java | 73 import java.util.concurrent.Future;
978 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, in handshake()
982 Future<TestSSLHandshakeCallbacks> future = in handshake()
1076 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_normal()
1077 Future<TestSSLHandshakeCallbacks> server = in test_SSL_do_handshake_normal()
1103 Future<TestSSLHandshakeCallbacks> client1 = handshake(listener, 0, true, new ClientHooks() { in test_SSL_do_handshake_reusedSession()
1109 Future<TestSSLHandshakeCallbacks> server1 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1139 Future<TestSSLHandshakeCallbacks> client2 = handshake(listener, 0, true, new ClientHooks() { in test_SSL_do_handshake_reusedSession()
1147 Future<TestSSLHandshakeCallbacks> server2 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1201 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
[all …]
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 29 import java.util.concurrent.Future;
73 List<Future<Boolean>> futureList = executor.invokeAll( in testNoOpScheduledExecutorInvokeAll()
75 Future<Boolean> future = futureList.get(0); in testNoOpScheduledExecutorInvokeAll()
94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule( in testSameThreadScheduledExecutor()
107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); in testSameThreadScheduledExecutorWithException()
|
| /external/guice/core/test/com/google/inject/internal/ |
| D | CycleDetectingLockTest.java | 13 import java.util.concurrent.Future;
83 Future<Void> firstThreadResult = in testSingletonThreadsRuntimeCircularDependency()
98 Future<Void> secondThreadResult = in testSingletonThreadsRuntimeCircularDependency()
139 Future<Boolean> threadA = in testCycleDetectingLockFactoriesDoNotDeadlock()
156 Future<Boolean> threadB = in testCycleDetectingLockFactoriesDoNotDeadlock()
200 ImmutableList<Future<ListMultimap<Thread, String>>> futures = in testCycleReporting()
209 for (Future<ListMultimap<Thread, String>> future : futures) { in testCycleReporting()
226 private static <T> Future<ListMultimap<Thread, T>> grabLocksInThread( in grabLocksInThread()
|
| /external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/ |
| D | NativeCryptoTest.java | 74 import java.util.concurrent.Future;
986 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, in handshake()
990 Future<TestSSLHandshakeCallbacks> future = in handshake()
1084 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_normal()
1085 Future<TestSSLHandshakeCallbacks> server = in test_SSL_do_handshake_normal()
1111 Future<TestSSLHandshakeCallbacks> client1 = handshake(listener, 0, true, new ClientHooks() { in test_SSL_do_handshake_reusedSession()
1117 Future<TestSSLHandshakeCallbacks> server1 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1147 Future<TestSSLHandshakeCallbacks> client2 = handshake(listener, 0, true, new ClientHooks() { in test_SSL_do_handshake_reusedSession()
1155 Future<TestSSLHandshakeCallbacks> server2 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1209 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | FakeClock.java | 28 import java.util.concurrent.Future;
137 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
141 @Override public <T> List<Future<T>> invokeAll( in invokeAll()
171 @Override public <T> Future<T> submit(Callable<T> task) { in submit()
175 @Override public Future<?> submit(Runnable task) { in submit()
179 @Override public <T> Future<T> submit(Runnable task, T result) { in submit()
185 Future<?> unused = schedule(command, 0, TimeUnit.NANOSECONDS); in execute()
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
| D | MockServerSocketTest.java | 25 import java.util.concurrent.Future;
84 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testCloseWhileAccept()
100 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testAccept()
121 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testConnect()
137 final Future<Void> f = executor.submit(new Callable<Void>() { in testWaitForAccept()
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | FutureResultAdapter.java | 5 import java.util.concurrent.Future;
13 Future<?> m_future;
15 public FutureResultAdapter(Future<?> future) { in FutureResultAdapter()
|
| /external/python/cpython3/Lib/asyncio/ |
| D | futures.py | 32 class Future: class
269 _PyFuture = Future
334 concurrent.futures.Future):
337 concurrent.futures.Future):
372 assert isinstance(future, concurrent.futures.Future), \
387 Future = _CFuture = _asyncio.Future variable
|
| /external/clang/test/SemaCXX/ |
| D | decltype.cpp | 20 struct Future { struct
21 explicit Future(T v);
36 Future<int> f1(42); in rdar16527205() argument
37 f1.call([](int){ return Future<float>(0); }); in rdar16527205()
|