Lines Matching refs:q
20 def qfull(q): argument
21 return q.maxsize > 0 and q.qsize() == q.maxsize
95 def basic_queue_test(self, q): argument
96 if q.qsize():
98 self.assertTrue(q.empty())
99 self.assertFalse(q.full())
101 q.put(111)
102 q.put(333)
103 q.put(222)
107 actual_order = [q.get(), q.get(), q.get()]
108 self.assertEqual(actual_order, target_order[q.__class__.__name__],
111 q.put(i)
112 self.assertTrue(q.qsize(), "Queue should not be empty")
113 self.assertTrue(not qfull(q), "Queue should not be full")
116 q.put(last)
117 self.assertTrue(qfull(q), "Queue should be full")
118 self.assertFalse(q.empty())
119 self.assertTrue(q.full())
121 q.put(full, block=0)
126 q.put(full, timeout=0.01)
131 self.do_blocking_test(q.put, (full,), q.get, ())
132 self.do_blocking_test(q.put, (full, True, 10), q.get, ())
135 q.get()
136 self.assertTrue(not q.qsize(), "Queue should be empty")
138 q.get(block=0)
143 q.get(timeout=0.01)
148 self.do_blocking_test(q.get, (), q.put, ('empty',))
149 self.do_blocking_test(q.get, (True, 10), q.put, ('empty',))
152 def worker(self, q): argument
154 x = q.get()
156 q.task_done()
160 q.task_done()
162 def queue_join_test(self, q): argument
166 thread = threading.Thread(target=self.worker, args=(q,))
170 q.put(i)
171 q.join()
175 q.put(-1) # instruct the threads to close
176 q.join() # verify that you can join twice
182 q = self.type2test()
184 q.task_done()
193 q = self.type2test()
194 self.queue_join_test(q)
195 self.queue_join_test(q)
197 q.task_done()
206 q = self.type2test(QUEUE_SIZE)
207 self.basic_queue_test(q)
208 self.basic_queue_test(q)
211 q = self.type2test(QUEUE_SIZE)
213 q.put(1, timeout=-1)
215 q.get(1, timeout=-1)
218 q = self.type2test(QUEUE_SIZE)
220 q.put_nowait(1)
222 q.put_nowait(1)
225 q.get_nowait()
227 q.get_nowait()
231 q = self.type2test(3)
232 q.put(1)
233 q.put(2)
234 q.put(3)
236 q.put_nowait(4)
237 self.assertEqual(q.qsize(), 3)
238 q.maxsize = 2 # shrink the queue
240 q.put_nowait(4)
318 def failing_queue_test(self, q): argument
319 if q.qsize():
322 q.put(i)
324 q.fail_next_put = True
326 q.put("oops", block=0)
330 q.fail_next_put = True
332 q.put("oops", timeout=0.1)
336 q.put("last")
337 self.assertTrue(qfull(q), "Queue should be full")
339 q.fail_next_put = True
341 self.do_blocking_test(q.put, ("full",), q.get, ())
347 q.put("last")
349 q.fail_next_put = True
351 self.do_exceptional_blocking_test(q.put, ("full", True, 10), q.get, (),
358 q.put("last")
359 self.assertTrue(qfull(q), "Queue should be full")
360 q.get()
361 self.assertTrue(not qfull(q), "Queue should not be full")
362 q.put("last")
363 self.assertTrue(qfull(q), "Queue should be full")
365 self.do_blocking_test(q.put, ("full",), q.get, ())
368 q.get()
369 self.assertTrue(not q.qsize(), "Queue should be empty")
370 q.put("first")
371 q.fail_next_get = True
373 q.get()
377 self.assertTrue(q.qsize(), "Queue should not be empty")
378 q.fail_next_get = True
380 q.get(timeout=0.1)
384 self.assertTrue(q.qsize(), "Queue should not be empty")
385 q.get()
386 self.assertTrue(not q.qsize(), "Queue should be empty")
387 q.fail_next_get = True
389 self.do_exceptional_blocking_test(q.get, (), q.put, ('empty',),
395 self.assertTrue(q.qsize(), "Queue should not be empty")
396 q.get()
397 self.assertTrue(not q.qsize(), "Queue should be empty")
403 q = self.FailingQueue(QUEUE_SIZE)
404 self.failing_queue_test(q)
405 self.failing_queue_test(q)
421 self.q = self.type2test()
423 def feed(self, q, seq, rnd, sentinel): argument
428 q.put(sentinel)
430 q.put(val)
434 def consume(self, q, results, sentinel): argument
436 val = q.get()
441 def consume_nonblock(self, q, results, sentinel): argument
445 val = q.get(block=False)
454 def consume_timeout(self, q, results, sentinel): argument
458 val = q.get(timeout=1e-5)
467 def run_threads(self, n_threads, q, inputs, feed_func, consume_func): argument
484 args=(q, seq, rnd, sentinel))
487 args=(q, results, sentinel))
494 self.assertTrue(q.empty())
495 self.assertEqual(q.qsize(), 0)
501 q = self.q
502 self.assertTrue(q.empty())
503 self.assertEqual(q.qsize(), 0)
504 q.put(1)
505 self.assertFalse(q.empty())
506 self.assertEqual(q.qsize(), 1)
507 q.put(2)
508 q.put_nowait(3)
509 q.put(4)
510 self.assertFalse(q.empty())
511 self.assertEqual(q.qsize(), 4)
513 self.assertEqual(q.get(), 1)
514 self.assertEqual(q.qsize(), 3)
516 self.assertEqual(q.get_nowait(), 2)
517 self.assertEqual(q.qsize(), 2)
519 self.assertEqual(q.get(block=False), 3)
520 self.assertFalse(q.empty())
521 self.assertEqual(q.qsize(), 1)
523 self.assertEqual(q.get(timeout=0.1), 4)
524 self.assertTrue(q.empty())
525 self.assertEqual(q.qsize(), 0)
528 q.get(block=False)
530 q.get(timeout=1e-3)
532 q.get_nowait()
533 self.assertTrue(q.empty())
534 self.assertEqual(q.qsize(), 0)
537 q = self.q
538 q.put(1)
540 q.get(timeout=-1)
544 q = self.q
546 results = self.run_threads(1, q, inputs, self.feed, self.consume)
554 q = self.q
556 results = self.run_threads(N, q, inputs, self.feed, self.consume)
565 q = self.q
567 results = self.run_threads(N, q, inputs,
575 q = self.q
577 results = self.run_threads(N, q, inputs,
589 q = self.q
591 q.put(C())
593 wr = weakref.ref(q.get())
622 q = self.q
635 q.put(next(gen))
639 q.put(next(gen))
641 results.append(q.get())