| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_queues.py | 301 self.loop.run_until_complete(self.loop.create_task(consumer(queue)))
361 reader = loop.create_task(q.get())
373 reader = loop.create_task(q.get())
390 reader1 = loop.create_task(q.get())
391 reader2 = loop.create_task(q.get())
392 reader3 = loop.create_task(q.get())
422 writer = loop.create_task(q.put(2))
433 writer = loop.create_task(q.put(2))
535 put_task = loop.create_task(queue.put(1))
558 put_task = loop.create_task(queue.put(1))
|
| D | test_runners.py | 111 lo_task = asyncio.create_task(leftover())
132 lo_task = asyncio.create_task(leftover())
170 lazyboy = asyncio.create_task(spin())
|
| D | test_server.py | 50 main_task = self.loop.create_task(main(srv))
104 main_task = self.loop.create_task(main(srv))
|
| D | test_subprocess.py | 342 task = self.loop.create_task(proc.wait())
363 task = self.loop.create_task(coro)
381 task = self.loop.create_task(coro)
|
| D | test_selector_events.py | 192 f = self.loop.create_task(self.loop.sock_recv(sock, 1024))
210 fut = self.loop.create_task(
273 f = self.loop.create_task(
290 f = self.loop.create_task(self.loop.sock_sendall(sock, b''))
305 fut = self.loop.create_task(self.loop.sock_sendall(sock, b'data'))
426 fut = self.loop.create_task(
447 con = self.loop.create_task(self.loop.sock_connect(sock, addr))
528 f = self.loop.create_task(self.loop.sock_accept(sock))
|
| D | test_locks.py | 226 t0 = self.loop.create_task(lockandtrigger())
227 t1 = self.loop.create_task(lockit())
228 t2 = self.loop.create_task(lockit())
229 t3 = self.loop.create_task(lockit())
|
| D | test_windows_events.py | 103 task = self.loop.create_task(coro)
|
| D | test_base_events.py | 747 task = self.loop.create_task(coro())
754 task = self.loop.create_task(coro())
798 def create_task(self, coro): member in BaseEventLoopTests.test_create_task.EventLoop
939 asyncio.create_task(iter_one())
941 asyncio.create_task(iter_one())
|
| D | test_tasks.py | 403 task = self.loop.create_task(partial_func(2))
1231 a = loop.create_task(asyncio.sleep(0.1, 'a', loop=loop))
1232 b = loop.create_task(asyncio.sleep(0.15, 'b', loop=loop))
2115 task = loop.create_task(blocking_coroutine())
2117 wait = loop.create_task(asyncio.wait_for(task, timeout, loop=loop))
2288 task = asyncio.create_task(inner())
2367 task = loop.create_task(sub(random.randint(0, 10)))
|
| D | utils.py | 99 t = loop.create_task(gen)
|
| D | test_streams.py | 590 self.loop.create_task(self.handle_client(client_reader,
659 self.loop.create_task(self.handle_client(client_reader,
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-future.rst | 47 See also the :func:`create_task` function which is the
215 # We are using the low-level "loop.create_task()" API here because
217 # Otherwise we could have just used "asyncio.create_task()".
218 loop.create_task(
|
| D | asyncio-task.rst | 76 * The :func:`asyncio.create_task` function to run coroutines
83 task1 = asyncio.create_task(
86 task2 = asyncio.create_task(
160 :func:`asyncio.create_task` the coroutine is automatically
171 task = asyncio.create_task(nested())
236 .. function:: create_task(coro)
253 task = asyncio.create_task(coro())
541 task = asyncio.create_task(foo())
658 Use the high-level :func:`asyncio.create_task` function to create
659 Tasks, or the low-level :meth:`loop.create_task` or
[all …]
|
| D | asyncio-dev.rst | 148 or the coroutine is not scheduled with :meth:`asyncio.create_task`, asyncio
180 :meth:`asyncio.create_task` function::
202 asyncio.create_task(bug())
|
| D | asyncio-llapi-index.rst | 120 * - :meth:`loop.create_task`
124 - Set a factory used by :meth:`loop.create_task` to
128 - Get the factory :meth:`loop.create_task` uses
|
| D | asyncio-api-index.rst | 24 * - :func:`create_task`
|
| D | asyncio-queue.rst | 181 task = asyncio.create_task(worker(f'worker-{i}', queue))
|
| D | asyncio-sync.rst | 111 waiter_task = asyncio.create_task(waiter(event))
|
| /external/python/cpython3/Lib/asyncio/ |
| D | tasks.py | 319 def create_task(coro): function
325 return loop.create_task(coro)
581 task = loop.create_task(coro_or_future)
|
| D | base_subprocess.py | 53 self._loop.create_task(self._connect_pipes(waiter))
|
| D | events.py | 280 def create_task(self, coro): member in AbstractEventLoop
|
| D | streams.py | 239 self._loop.create_task(res)
|
| D | base_events.py | 398 def create_task(self, coro): member in BaseEventLoop
485 self.call_soon_threadsafe(self.create_task, agen.aclose())
|
| /external/python/cpython3/Lib/test/ |
| D | test_asyncgen.py | 592 t = self.loop.create_task(it.__anext__())
994 t1 = self.loop.create_task(wait())
995 t2 = self.loop.create_task(wait())
1028 t = self.loop.create_task(wait())
|
| /external/python/cpython3/Misc/NEWS.d/ |
| D | 3.7.0a4.rst | 344 Optimize asyncio.iscoroutine() and loop.create_task() for non-native
347 'loop.create_task(python_coroutine)' used to be 20% faster than
348 'loop.create_task(cython_coroutine)'. Now, the latter is as fast.
418 Implement asyncio.create_task(coro) shortcut
|