Home
last modified time | relevance | path

Searched refs:create_task (Results 1 - 25 of 32) sorted by relevance

12

/third_party/python/Lib/test/test_asyncio/
H A Dtest_taskgroups.py42 t1 = g.create_task(foo1())
43 t2 = g.create_task(foo2())
59 t1 = g.create_task(foo1())
61 t2 = g.create_task(foo2())
77 t1 = g.create_task(foo1())
83 t2 = g.create_task(foo2())
111 g.create_task(foo1())
112 t2 = g.create_task(foo2())
117 await asyncio.create_task(runner())
150 g.create_task(foo
[all...]
H A Dtest_queues.py29 getter = tg.create_task(q.get())
43 putter = tg.create_task(q.put(2))
102 t = asyncio.create_task(putter())
154 queue_get_task = asyncio.create_task(queue_get())
174 t1 = asyncio.create_task(q.get())
175 t2 = asyncio.create_task(q.get())
187 asyncio.create_task(q.put('a'))
188 asyncio.create_task(q.put('b'))
205 tg.create_task(producer(q, producer_num_items))
206 tg.create_task(consume
[all...]
H A Dtest_locks.py107 t1 = asyncio.create_task(c1(result))
108 t2 = asyncio.create_task(c2(result))
120 t3 = asyncio.create_task(c3(result))
141 task = asyncio.create_task(lock.acquire())
173 ta = asyncio.create_task(lockit('A', fa))
176 tb = asyncio.create_task(lockit('B', None))
179 tc = asyncio.create_task(lockit('C', None))
216 t1 = asyncio.create_task(lockit())
217 t2 = asyncio.create_task(lockit())
218 t3 = asyncio.create_task(locki
[all...]
H A Dtest_waitfor.py44 waitfortask = asyncio.create_task(
111 fut = asyncio.create_task(foo())
138 fut = asyncio.create_task(foo())
188 inner_task = asyncio.create_task(inner())
211 inner_task = asyncio.create_task(inner())
233 inner_task = asyncio.create_task(inner())
252 inner_task = asyncio.create_task(inner())
258 task = asyncio.create_task(wait)
275 task = asyncio.create_task(blocking_coroutine())
277 wait = asyncio.create_task(asynci
[all...]
H A Dtest_sock_lowlevel.py139 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
143 asyncio.create_task(
157 task = asyncio.create_task(
162 task = asyncio.create_task(
178 task = asyncio.create_task(
196 task = asyncio.create_task(
209 task = asyncio.create_task(recv_all())
231 task = asyncio.create_task(self.loop.sock_connect(sock, addr))
292 task = asyncio.create_task(self.loop.sock_sendall(sock, chunk))
341 task = asyncio.create_task(sel
[all...]
H A 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(sel
[all...]
H A Dtest_server.py53 main_task = self.loop.create_task(main(srv))
107 main_task = self.loop.create_task(main(srv))
H A Dtest_runners.py131 lo_task = asyncio.create_task(leftover())
152 lo_task = asyncio.create_task(leftover())
190 lazyboy = asyncio.create_task(spin())
435 asyncio.create_task(subtask(asyncio.current_task()))
H A Dtest_base_events.py734 task = self.loop.create_task(coro())
741 task = self.loop.create_task(coro())
784 def create_task(self, coro): member in BaseEventLoopTests.test_create_task.EventLoop
814 task = loop.create_task(test(), name='test_task')
830 task = loop.create_task(test(), name='test_task')
962 asyncio.create_task(iter_one())
964 asyncio.create_task(iter_one())
1092 return self.loop.create_task(getaddrinfo(*args, **kwds))
1209 return self.loop.create_task(getaddrinfo(*args, **kwds))
1221 return self.loop.create_task(getaddrinf
[all...]
H A Dtest_windows_events.py153 task = self.loop.create_task(coro)
282 await self.loop.create_task(probe())
H A Dtest_timeouts.py162 task = asyncio.create_task(outer())
206 task = asyncio.create_task(f())
H A Dtest_subprocess.py460 task = self.loop.create_task(proc.wait())
480 task = self.loop.create_task(coro)
498 task = self.loop.create_task(coro)
H A Dtest_pep492.py190 t = self.loop.create_task(coro)
H A Dtest_tasks.py1119 c = self.loop.create_task(coro('test'))
1122 asyncio.wait([c, c, self.loop.create_task(coro('spam'))]))
1414 a = loop.create_task(asyncio.sleep(0.1, 'a'))
1415 b = loop.create_task(asyncio.sleep(0.15, 'b'))
1854 d, p = await asyncio.wait([asyncio.create_task(inner())])
2245 task = asyncio.create_task(inner())
2258 task = asyncio.create_task(coro_noop(), name='No-op')
2335 task = loop.create_task(sub(random.randint(0, 10)))
2387 t1 = asyncio.create_task(coro(1), context=ctx)
2390 t2 = asyncio.create_task(cor
[all...]
H A Dutils.py101 t = loop.create_task(gen)
H A Dtest_events.py805 return self.loop.create_task(getaddrinfo(*args, **kwds))
1652 f = self.loop.create_task(self.loop.sock_recv(r, 1))
1670 t = self.loop.create_task(main())
1767 self.loop.create_task(coro)
2493 NotImplementedError, loop.create_task, None)
/third_party/python/Lib/asyncio/
H A Dtaskgroups.py18 task1 = group.create_task(some_coroutine(...))
19 task2 = group.create_task(other_coroutine(...))
92 # g.create_task(...)
98 # g.create_task(...)
119 # g.create_task(foo)
151 def create_task(self, coro, *, name=None, context=None): member in TaskGroup
154 Similar to `asyncio.create_task`.
163 task = self._loop.create_task(coro)
165 task = self._loop.create_task(coro, context=context)
225 # g.create_task(crash_soo
[all...]
H A Dstaggered.py99 next_task = loop.create_task(run_one_coro(this_failed))
130 first_task = loop.create_task(run_one_coro(None))
H A Dtasks.py4 'Task', 'create_task',
366 def create_task(coro, *, name=None, context=None): function
374 task = loop.create_task(coro)
376 task = loop.create_task(coro, context=context)
670 return loop.create_task(coro_or_future)
846 task = asyncio.create_task(something())
863 task = asyncio.create_task(something())
H A D__main__.py50 repl_future = self.loop.create_task(coro)
H A Drunners.py100 task = self._loop.create_task(coro, context=context)
H A Dbase_subprocess.py53 self._loop.create_task(self._connect_pipes(waiter))
H A Devents.py277 def create_task(self, coro, *, name=None, context=None): member in AbstractEventLoop
/third_party/python/Lib/test/
H A Dtest_asyncgen.py1135 task = asyncio.create_task(target())
1448 t1 = self.loop.create_task(wait())
1449 t2 = self.loop.create_task(wait())
1667 asyncio.create_task(ag.aclose())
/third_party/python/Lib/unittest/test/
H A Dtest_async_case.py390 asyncio.create_task(coro())

Completed in 29 milliseconds

12