90     def simple_queue_test(self, q):  argument
91         if not q.empty():
94         q.put(111)
95         q.put(333)
96         q.put(222)
100         actual_order = [q.get(), q.get(), q.get()]
101         self.assertEqual(actual_order, target_order[q.__class__.__name__],
104             q.put(i)
105             self.assertTrue(not q.empty(), "Queue should not be empty")
106         self.assertTrue(not q.full(), "Queue should not be full")
109         q.put(last)
110         self.assertTrue(q.full(), "Queue should be full")
112             q.put(full, block=0)
117             q.put(full, timeout=0.01)
122         self.do_blocking_test(q.put, (full,), q.get, ())
123         self.do_blocking_test(q.put, (full, True, 10), q.get, ())
126             q.get()
127         self.assertTrue(q.empty(), "Queue should be empty")
129             q.get(block=0)
134             q.get(timeout=0.01)
139         self.do_blocking_test(q.get, (), q.put, ('empty',))
140         self.do_blocking_test(q.get, (True, 10), q.put, ('empty',))
143     def worker(self, q):  argument
145             x = q.get()
147                 q.task_done()
151             q.task_done()
153     def queue_join_test(self, q):  argument
156             threading.Thread(target=self.worker, args=(q,)).start()
158             q.put(i)
159         q.join()
163             q.put(None)         # instruct the threads to close
164         q.join()                # verify that you can join twice
168         q = self.type2test()
170             q.task_done()
179         q = self.type2test()
180         self.queue_join_test(q)
181         self.queue_join_test(q)
183             q.task_done()
192         q = self.type2test(QUEUE_SIZE)
193         self.simple_queue_test(q)
194         self.simple_queue_test(q)
230     def failing_queue_test(self, q):  argument
231         if not q.empty():
234             q.put(i)
236         q.fail_next_put = True
238             q.put("oops", block=0)
242         q.fail_next_put = True
244             q.put("oops", timeout=0.1)
248         q.put("last")
249         self.assertTrue(q.full(), "Queue should be full")
251         q.fail_next_put = True
253             self.do_blocking_test(q.put, ("full",), q.get, ())
259         q.put("last")
261         q.fail_next_put = True
263             self.do_exceptional_blocking_test(q.put, ("full", True, 10), q.get, (),
270         q.put("last")
271         self.assertTrue(q.full(), "Queue should be full")
272         q.get()
273         self.assertTrue(not q.full(), "Queue should not be full")
274         q.put("last")
275         self.assertTrue(q.full(), "Queue should be full")
277         self.do_blocking_test(q.put, ("full",), q.get, ())
280             q.get()
281         self.assertTrue(q.empty(), "Queue should be empty")
282         q.put("first")
283         q.fail_next_get = True
285             q.get()
289         self.assertTrue(not q.empty(), "Queue should not be empty")
290         q.fail_next_get = True
292             q.get(timeout=0.1)
296         self.assertTrue(not q.empty(), "Queue should not be empty")
297         q.get()
298         self.assertTrue(q.empty(), "Queue should be empty")
299         q.fail_next_get = True
301             self.do_exceptional_blocking_test(q.get, (), q.put, ('empty',),
307         self.assertTrue(not q.empty(), "Queue should not be empty")
308         q.get()
309         self.assertTrue(q.empty(), "Queue should be empty")
314         q = FailingQueue(QUEUE_SIZE)
315         self.failing_queue_test(q)
316         self.failing_queue_test(q)