Home
last modified time | relevance | path

Searched refs:create_task (Results 1 – 25 of 41) sorted by relevance

12

/third_party/python/Lib/test/test_asyncio/
Dtest_locks.py114 t1 = asyncio.create_task(c1(result))
115 t2 = asyncio.create_task(c2(result))
127 t3 = asyncio.create_task(c3(result))
148 task = asyncio.create_task(lock.acquire())
180 ta = asyncio.create_task(lockit('A', fa))
183 tb = asyncio.create_task(lockit('B', None))
186 tc = asyncio.create_task(lockit('C', None))
223 t1 = asyncio.create_task(lockit())
224 t2 = asyncio.create_task(lockit())
225 t3 = asyncio.create_task(lockit())
[all …]
Dtest_queues.py46 loop.create_task(q.get())
59 loop.create_task(q.put(2))
123 t = loop.create_task(putter())
189 queue_get_task = loop.create_task(queue_get())
226 get_task = loop.create_task(queue_get())
237 t1 = self.loop.create_task(q.get())
238 t2 = self.loop.create_task(q.get())
250 self.loop.create_task(q.put('a'))
251 self.loop.create_task(q.put('b'))
297 self.loop.run_until_complete(self.loop.create_task(consumer(queue)))
[all …]
Dtest_sock_lowlevel.py136 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
140 asyncio.create_task(
154 task = asyncio.create_task(
159 task = asyncio.create_task(
175 task = asyncio.create_task(
193 task = asyncio.create_task(
206 task = asyncio.create_task(recv_all())
228 task = asyncio.create_task(self.loop.sock_connect(sock, addr))
289 task = asyncio.create_task(self.loop.sock_sendall(sock, chunk))
338 task = asyncio.create_task(self.loop.sock_sendall(sock, chunk))
Dtest_streams.py151 read_task = self.loop.create_task(stream.read(30))
175 read_task = self.loop.create_task(stream.read(1024))
188 read_task = self.loop.create_task(stream.read(-1))
231 read_task = self.loop.create_task(stream.readline())
487 read_task = self.loop.create_task(stream.readexactly(n))
510 read_task = self.loop.create_task(stream.readexactly(n))
550 t1 = self.loop.create_task(stream.readline())
551 t2 = self.loop.create_task(set_err())
560 t = self.loop.create_task(stream.readline())
592 self.loop.create_task(self.handle_client(client_reader,
[all …]
Dtest_runners.py114 lo_task = asyncio.create_task(leftover())
135 lo_task = asyncio.create_task(leftover())
173 lazyboy = asyncio.create_task(spin())
Dtest_server.py53 main_task = self.loop.create_task(main(srv))
107 main_task = self.loop.create_task(main(srv))
Dtest_base_events.py740 task = self.loop.create_task(coro())
747 task = self.loop.create_task(coro())
790 def create_task(self, coro): member in BaseEventLoopTests.test_create_task.EventLoop
809 task = loop.create_task(test(), name='test_task')
825 task = loop.create_task(test(), name='test_task')
957 asyncio.create_task(iter_one())
959 asyncio.create_task(iter_one())
1087 return self.loop.create_task(getaddrinfo(*args, **kwds))
1204 return self.loop.create_task(getaddrinfo(*args, **kwds))
1216 return self.loop.create_task(getaddrinfo(*args, **kwds))
[all …]
Dtest_asyncio_waitfor.py36 waitfortask = asyncio.create_task(asyncio.wait_for(t.run(), t.TASK_TIMEOUT * 2))
Dtest_subprocess.py411 task = self.loop.create_task(proc.wait())
431 task = self.loop.create_task(coro)
449 task = self.loop.create_task(coro)
Dtest_pep492.py204 t = self.loop.create_task(coro)
Dtest_tasks.py541 task = self.loop.create_task(partial_func(2))
1609 a = loop.create_task(asyncio.sleep(0.1, 'a'))
1610 b = loop.create_task(asyncio.sleep(0.15, 'b'))
2549 task = loop.create_task(blocking_coroutine())
2551 wait = loop.create_task(asyncio.wait_for(task, timeout))
2739 task = asyncio.create_task(inner())
2752 task = asyncio.create_task(coro_noop(), name='No-op')
2829 task = loop.create_task(sub(random.randint(0, 10)))
3070 task = self.loop.create_task(coro())
3736 task = self.loop.create_task(coroutine_function())
Dtest_windows_events.py153 task = self.loop.create_task(coro)
/third_party/python/Lib/asyncio/
Dstaggered.py99 next_task = loop.create_task(run_one_coro(this_failed))
130 first_task = loop.create_task(run_one_coro(None))
Dtasks.py331 def create_task(coro, *, name=None): function
337 task = loop.create_task(coro)
634 return loop.create_task(coro_or_future)
D__main__.py50 repl_future = self.loop.create_task(coro)
Dbase_subprocess.py53 self._loop.create_task(self._connect_pipes(waiter))
/third_party/python/Doc/library/
Dasyncio-future.rst54 See also the :func:`create_task` function which is the
240 # We are using the low-level "loop.create_task()" API here because
242 # Otherwise we could have just used "asyncio.create_task()".
243 loop.create_task(
Dasyncio-task.rst76 * 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())
250 .. function:: create_task(coro, *, name=None)
270 task = asyncio.create_task(coro())
635 task = asyncio.create_task(foo())
836 Use the high-level :func:`asyncio.create_task` function to create
837 Tasks, or the low-level :meth:`loop.create_task` or
[all …]
Dasyncio-dev.rst158 or the coroutine is not scheduled with :meth:`asyncio.create_task`, asyncio
190 :meth:`asyncio.create_task` function::
212 asyncio.create_task(bug())
Dasyncio-llapi-index.rst120 * - :meth:`loop.create_task`
124 - Set a factory used by :meth:`loop.create_task` to
128 - Get the factory :meth:`loop.create_task` uses
Dasyncio-api-index.rst24 * - :func:`create_task`
/third_party/python/Misc/NEWS.d/
D3.7.0a4.rst344 Optimize asyncio.iscoroutine() and loop.create_task() for non-native
346 'loop.create_task(python_coroutine)' used to be 20% faster than
347 'loop.create_task(cython_coroutine)'. Now, the latter is as fast.
417 Implement asyncio.create_task(coro) shortcut
/third_party/python/Lib/unittest/
Dasync_case.py117 self._asyncioCallsTask = loop.create_task(self._asyncioLoopRunner(fut))
/third_party/python/Lib/test/
Dtest_asyncgen.py1133 task = asyncio.create_task(target())
1446 t1 = self.loop.create_task(wait())
1447 t2 = self.loop.create_task(wait())
1665 asyncio.create_task(ag.aclose())
/third_party/python/Lib/unittest/test/
Dtest_async_case.py294 asyncio.create_task(coro())

12