Lines Matching defs:asyncio

3 import asyncio
9     asyncio.set_event_loop_policy(None)
20         q = asyncio.Queue()
26         q = asyncio.Queue()
27         async with asyncio.TaskGroup() as tg:
31             await asyncio.sleep(0)
39         q = asyncio.Queue(maxsize=1)
40         async with asyncio.TaskGroup() as tg:
45             await asyncio.sleep(0)
52         q = asyncio.Queue()
63         q = asyncio.Queue[int]
68         q = asyncio.Queue()
76         q = asyncio.Queue()
79         q = asyncio.Queue(maxsize=1)
84         q = asyncio.Queue()
92         q = asyncio.Queue(maxsize=2)
102         t = asyncio.create_task(putter())
104             await asyncio.sleep(0)
111         await asyncio.sleep(0)
123         q = asyncio.Queue()
129         loop = asyncio.get_running_loop()
131         q = asyncio.Queue(1)
142         loop = asyncio.get_running_loop()
143         q = asyncio.Queue()
144         started = asyncio.Event()
154         queue_get_task = asyncio.create_task(queue_get())
163         q = asyncio.Queue()
168         q = asyncio.Queue()
169         self.assertRaises(asyncio.QueueEmpty, q.get_nowait)
172         q = asyncio.Queue()
174         t1 = asyncio.create_task(q.get())
175         t2 = asyncio.create_task(q.get())
177         await asyncio.sleep(0)
179         await asyncio.sleep(0)
182         await asyncio.sleep(0)
186         q = asyncio.Queue(maxsize=1)
187         asyncio.create_task(q.put('a'))
188         asyncio.create_task(q.put('b'))
203         q = asyncio.Queue(1)
204         async with asyncio.TaskGroup() as tg:
209         queue = asyncio.Queue(maxsize=5)
212             await asyncio.wait_for(queue.get(), 0.1)
220         q = asyncio.Queue()
227         q = asyncio.Queue(maxsize=1)
228         started = asyncio.Event()
238         loop = asyncio.get_running_loop()
240         queue_put_task = asyncio.create_task(queue_put())
247         q = asyncio.Queue()
252         q = asyncio.Queue()
254         reader = asyncio.create_task(q.get())
256         await asyncio.sleep(0)
264         except asyncio.CancelledError:
266             reader = asyncio.create_task(q.get())
274         q = asyncio.Queue()
276         async with asyncio.TaskGroup() as tg:
281             await asyncio.sleep(0)
287             with self.assertRaises(asyncio.CancelledError):
296         q = asyncio.Queue(1)
301         writer = asyncio.create_task(q.put(2))
302         await asyncio.sleep(0)
310         except asyncio.CancelledError:
312             writer = asyncio.create_task(q.put(2))
320         q = asyncio.Queue(maxsize=1, )
322         self.assertRaises(asyncio.QueueFull, q.put_nowait, 2)
325         q = asyncio.Queue(maxsize=1.3, )
329         self.assertRaises(asyncio.QueueFull, q.put_nowait, 3)
331         q = asyncio.Queue(maxsize=1.3, )
338         q = asyncio.Queue()
344         t = asyncio.create_task(queue_put())
351         q = asyncio.Queue(maxsize=1)
353         put_a = asyncio.create_task(q.put('a'))
354         put_b = asyncio.create_task(q.put('b'))
355         put_c = asyncio.create_task(q.put('X'))
357         await asyncio.sleep(0)
362         await asyncio.sleep(0)
365         await asyncio.sleep(0)
371         q = asyncio.Queue()
372         t = asyncio.create_task(q.get())
373         await asyncio.sleep(0)
378         queue = asyncio.Queue(2)
384             await asyncio.sleep(0)
389         async with asyncio.TaskGroup() as tg:
398         queue = asyncio.Queue(maxsize=1)
402         put_task = asyncio.create_task(queue.put(1))
403         await asyncio.sleep(0)
409         with self.assertRaises(asyncio.CancelledError):
415         queue = asyncio.Queue(1)
419         put_task = asyncio.create_task(queue.put(1))
420         await asyncio.sleep(0)
431         with self.assertRaises(asyncio.CancelledError):
438         q = asyncio.LifoQueue()
449         q = asyncio.PriorityQueue()
484         async with asyncio.TaskGroup() as tg:
514     q_class = asyncio.Queue
518     q_class = asyncio.LifoQueue
522     q_class = asyncio.PriorityQueue