Lines Matching refs:q
38 q = asyncio.Queue()
39 self.assertTrue(fn(q).startswith('<Queue'), fn(q))
40 id_is_present = hex(id(q)) in fn(q)
44 q = asyncio.Queue()
46 loop.create_task(q.get())
49 self.assertTrue('_getters[1]' in fn(q))
51 q.put_nowait(0)
56 q = asyncio.Queue(maxsize=1)
57 q.put_nowait(1)
59 loop.create_task(q.put(2))
62 self.assertTrue('_putters[1]' in fn(q))
64 q.get_nowait()
67 q = asyncio.Queue()
68 q.put_nowait(1)
69 self.assertTrue('_queue=[1]' in fn(q))
78 q = asyncio.Queue()
79 self.assertTrue(q.empty())
80 q.put_nowait(1)
81 self.assertFalse(q.empty())
82 self.assertEqual(1, q.get_nowait())
83 self.assertTrue(q.empty())
86 q = asyncio.Queue()
87 self.assertFalse(q.full())
89 q = asyncio.Queue(maxsize=1)
90 q.put_nowait(1)
91 self.assertTrue(q.full())
94 q = asyncio.Queue()
96 q.put_nowait(i)
98 items = [q.get_nowait() for _ in range(3)]
112 q = asyncio.Queue(maxsize=2)
113 self.assertEqual(2, q.maxsize)
118 await q.put(i)
128 self.assertEqual(0, q.get_nowait())
133 self.assertEqual(1, q.get_nowait())
134 self.assertEqual(2, q.get_nowait())
146 q = asyncio.Queue()
147 q.put_nowait(1)
150 return await q.get()
156 q = asyncio.Queue(1)
157 q.put_nowait(1)
160 q._putters.append(waiter)
162 res = self.loop.run_until_complete(q.get())
176 q = asyncio.Queue()
183 res = await q.get()
188 loop.call_later(0.01, q.put_nowait, 1)
201 q = asyncio.Queue()
202 q.put_nowait(1)
203 self.assertEqual(1, q.get_nowait())
206 q = asyncio.Queue()
207 self.assertRaises(asyncio.QueueEmpty, q.get_nowait)
220 q = asyncio.Queue()
223 return await asyncio.wait_for(q.get(), 0.051)
228 q.put_nowait(1)
235 q = asyncio.Queue()
237 t1 = self.loop.create_task(q.get())
238 t2 = self.loop.create_task(q.get())
244 q.put_nowait('a')
249 q = asyncio.Queue(maxsize=1)
250 self.loop.create_task(q.put('a'))
251 self.loop.create_task(q.put('b'))
253 self.assertEqual(self.loop.run_until_complete(q.get()), 'a')
254 self.assertEqual(self.loop.run_until_complete(q.get()), 'b')
277 q = await create_queue()
278 await asyncio.gather(producer(q, producer_num_items),
279 consumer(q, producer_num_items))
304 q = asyncio.Queue()
308 await q.put(1)
321 q = asyncio.Queue(maxsize=1)
328 await q.put(1)
329 await q.put(2)
333 loop.call_later(0.01, q.get_nowait)
344 q = asyncio.Queue()
345 q.put_nowait(1)
346 self.assertEqual(1, q.get_nowait())
355 q = asyncio.Queue()
357 reader = loop.create_task(q.get())
361 q.put_nowait(1)
362 q.put_nowait(2)
369 reader = loop.create_task(q.get())
384 q = asyncio.Queue()
386 reader1 = loop.create_task(q.get())
387 reader2 = loop.create_task(q.get())
388 reader3 = loop.create_task(q.get())
392 q.put_nowait(1)
393 q.put_nowait(2)
414 q = asyncio.Queue(1)
416 q.put_nowait(1)
419 writer = loop.create_task(q.put(2))
422 value1 = q.get_nowait()
430 writer = loop.create_task(q.put(2))
433 value2 = q.get_nowait()
435 self.assertEqual(q.qsize(), 0)
438 q = asyncio.Queue(maxsize=1, )
439 q.put_nowait(1)
440 self.assertRaises(asyncio.QueueFull, q.put_nowait, 2)
443 q = asyncio.Queue(maxsize=1.3, )
444 q.put_nowait(1)
445 q.put_nowait(2)
446 self.assertTrue(q.full())
447 self.assertRaises(asyncio.QueueFull, q.put_nowait, 3)
449 q = asyncio.Queue(maxsize=1.3, )
452 await q.put(1)
453 await q.put(2)
454 self.assertTrue(q.full())
458 q = asyncio.Queue()
461 await q.put(1)
465 return await q.get()
473 q = asyncio.Queue(maxsize=1)
475 put_a = self.loop.create_task(q.put('a'))
476 put_b = self.loop.create_task(q.put('b'))
477 put_c = self.loop.create_task(q.put('X'))
486 self.assertEqual(q.get_nowait(), 'a')
488 self.assertEqual(q.get_nowait(), 'b')
493 q = asyncio.Queue()
494 t = self.loop.create_task(q.get())
496 self.loop.run_until_complete(q.put('a'))
504 q = asyncio.Queue(2)
505 q._get_loop()
506 return q
582 q = asyncio.LifoQueue()
584 q.put_nowait(i)
586 items = [q.get_nowait() for _ in range(3)]
593 q = asyncio.PriorityQueue()
595 q.put_nowait(i)
597 items = [q.get_nowait() for _ in range(3)]
606 q = self.q_class()
607 self.assertRaises(ValueError, q.task_done)
610 q = self.q_class()
612 q.put_nowait(i)
624 item = await q.get()
626 q.task_done()
632 await q.join()
641 q.put_nowait(0)
645 q = self.q_class()
651 await q.join()
652 await q.join()
657 q = self.q_class()
658 self.assertEqual(q._format(), 'maxsize=0')
660 q._unfinished_tasks = 2
661 self.assertEqual(q._format(), 'maxsize=0 tasks=2')