Lines Matching refs:put
103 q.put(111)
104 q.put(333)
105 q.put(222)
113 q.put(i)
118 q.put(last)
123 q.put(full, block=0)
128 q.put(full, timeout=0.01)
132 # Test a blocking put
133 self.do_blocking_test(q.put, (full,), q.get, ())
134 self.do_blocking_test(q.put, (full, True, 10), q.get, ())
150 self.do_blocking_test(q.get, (), q.put, ('empty',))
151 self.do_blocking_test(q.get, (True, 10), q.put, ('empty',))
172 q.put(i)
177 q.put(-1) # instruct the threads to close
215 q.put(1, timeout=-1)
234 q.put(1)
235 q.put(2)
236 q.put(3)
325 q.put(i)
326 # Test a failing non-blocking put.
329 q.put("oops", block=0)
335 q.put("oops", timeout=0.1)
339 q.put("last")
341 # Test a failing blocking put
344 self.do_blocking_test(q.put, ("full",), q.get, ())
349 # put failed, but get succeeded - re-add
350 q.put("last")
351 # Test a failing timeout put
354 self.do_exceptional_blocking_test(q.put, ("full", True, 10), q.get, (),
360 # put failed, but get succeeded - re-add
361 q.put("last")
365 q.put("last")
367 # Test a blocking put
368 self.do_blocking_test(q.put, ("full",), q.get, ())
373 q.put("first")
392 self.do_exceptional_blocking_test(q.get, (), q.put, ('empty',),
397 # put succeeded, but get failed.
431 q.put(sentinel)
433 q.put(val)
503 # Basic tests for get(), put() etc.
507 q.put(1)
510 q.put(2)
512 q.put(4)
541 q.put(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=...)
594 q.put(C())
623 # bpo-14976: put() may be called reentrantly in an asynchronous
638 q.put(next(gen))
642 q.put(next(gen))