| /external/libcxx/test/std/thread/futures/futures.async/ |
| D | async_race.38682.pass.cpp | 47 std::future<int> fut = std::async(std::launch::async, worker, v); in main() local
56 std::future<int&> fut = std::async(std::launch::async, worker_ref, std::ref(i)); in main() local
65 std::future<void> fut = std::async(std::launch::async, worker_void); in main() local
|
| /external/python/cpython3/Modules/ |
| D | _asynciomodule.c | 198 get_future_loop(PyObject *fut) in get_future_loop()
381 future_is_alive(FutureObj *fut) in future_is_alive()
388 future_ensure_alive(FutureObj *fut) in future_ensure_alive()
399 #define ENSURE_FUTURE_ALIVE(fut) \ argument
409 future_schedule_callbacks(FutureObj *fut) in future_schedule_callbacks()
465 future_init(FutureObj *fut, PyObject *loop) in future_init()
521 future_set_result(FutureObj *fut, PyObject *res) in future_set_result()
544 future_set_exception(FutureObj *fut, PyObject *exc) in future_set_exception()
594 future_get_result(FutureObj *fut, PyObject **result) in future_get_result()
619 future_add_done_callback(FutureObj *fut, PyObject *arg, PyObject *ctx) in future_add_done_callback()
[all …]
|
| /external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/ |
| D | SimpleEchoSocket.java | 87 Future<Void> fut; in onConnect() local
|
| /external/python/cpython3/Lib/asyncio/ |
| D | selector_events.py | 354 def _sock_recv(self, fut, registered_fd, sock, n): argument
387 def _sock_recv_into(self, fut, registered_fd, sock, buf): argument
427 def _sock_sendall(self, fut, registered_fd, sock, data): argument
466 def _sock_connect(self, fut, sock, address): argument
483 def _sock_connect_done(self, fd, fut): argument
486 def _sock_connect_cb(self, fut, sock, address): argument
517 def _sock_accept(self, fut, registered, sock): argument
|
| D | tasks.py | 371 async def wait_for(fut, timeout, *, loop=None): argument
471 async def _cancel_and_wait(fut, loop): argument
664 def _done_callback(fut): argument
|
| D | futures.py | 272 def _get_loop(fut): argument
284 def _set_result_unless_cancelled(fut, result): argument
|
| D | unix_events.py | 341 def _sock_sendfile_native_impl(self, fut, registered_fd, sock, fileno, argument
413 def _sock_add_cancellation_callback(self, fut, sock): argument
414 def cb(fut): argument
|
| D | proactor_events.py | 246 def _loop_reading(self, fut=None): argument
412 def _pipe_closed(self, fut): argument
|
| D | windows_events.py | 122 def _unregister_wait_cb(self, fut): argument
196 def _unregister_wait_cb(self, fut): argument
|
| D | base_events.py | 158 def _run_until_complete_cb(fut): argument
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 116 async def run(fut): argument
381 async def wait_for(fut): argument
2322 def fut_on_done(fut): argument
3006 def coro(fut=fut): argument
|
| D | test_base_events.py | 288 def check_in_thread(loop, event, debug, create_loop, fut): argument
562 def zero_error(fut): argument
|
| /external/python/cpython3/Lib/test/ |
| D | test_types.py | 1533 def __init__(self, fut): argument
|