Lines Matching refs:tg
27 async with asyncio.TaskGroup() as tg:
29 getter = tg.create_task(q.get())
40 async with asyncio.TaskGroup() as tg:
43 putter = tg.create_task(q.put(2))
204 async with asyncio.TaskGroup() as tg:
205 tg.create_task(producer(q, producer_num_items))
206 tg.create_task(consumer(q, producer_num_items))
276 async with asyncio.TaskGroup() as tg:
277 reader1 = tg.create_task(q.get())
278 reader2 = tg.create_task(q.get())
279 reader3 = tg.create_task(q.get())
389 async with asyncio.TaskGroup() as tg:
390 tg.create_task(getter())
391 tg.create_task(putter(0))
392 tg.create_task(putter(1))
393 tg.create_task(putter(2))
394 tg.create_task(putter(3))
484 async with asyncio.TaskGroup() as tg:
485 tasks = [tg.create_task(worker())