Lines Matching refs:get
109 actual_order = [q.get(), q.get(), q.get()]
133 self.do_blocking_test(q.put, (full,), q.get, ())
134 self.do_blocking_test(q.put, (full, True, 10), q.get, ())
137 q.get()
140 q.get(block=0)
145 q.get(timeout=0.01)
149 # Test a blocking get
150 self.do_blocking_test(q.get, (), q.put, ('empty',))
151 self.do_blocking_test(q.get, (True, 10), q.put, ('empty',))
156 x = q.get()
217 q.get(1, timeout=-1)
344 self.do_blocking_test(q.put, ("full",), q.get, ())
349 # put failed, but get succeeded - re-add
354 self.do_exceptional_blocking_test(q.put, ("full", True, 10), q.get, (),
360 # put failed, but get succeeded - re-add
363 q.get()
368 self.do_blocking_test(q.put, ("full",), q.get, ())
371 q.get()
376 q.get()
383 q.get(timeout=0.1)
388 q.get()
392 self.do_exceptional_blocking_test(q.get, (), q.put, ('empty',),
397 # put succeeded, but get failed.
399 q.get()
439 val = q.get()
448 val = q.get(block=False)
461 val = q.get(timeout=1e-5)
503 # Basic tests for get(), put() etc.
516 self.assertEqual(q.get(), 1)
522 self.assertEqual(q.get(block=False), 3)
526 self.assertEqual(q.get(timeout=0.1), 4)
531 q.get(block=False)
533 q.get(timeout=1e-3)
543 q.get(timeout=-1)
546 # Test a pair of concurrent put() and get()
555 # Test multiple concurrent put() and get()
566 # Test multiple concurrent put() and get(block=False)
576 # Test multiple concurrent put() and get(timeout=...)
596 wr = weakref.ref(q.get())
644 results.append(q.get())