Lines Matching defs:queue
1 # Some simple queue module tests, plus some failure conditions
13 # queue module depends on threading primitives
16 py_queue = import_helper.import_fresh_module('queue', blocked=['_queue'])
17 c_queue = import_helper.import_fresh_module('queue', fresh=['_queue'])
50 # trigger_func must guarantee to change queue state so that block_func can make
99 raise RuntimeError("Call this function with an empty queue")
102 # I guess we better check things actually queue correctly a little :)
111 "Didn't seem to queue the correct data!")
124 self.fail("Didn't appear to block with a full queue")
125 except self.queue.Full:
129 self.fail("Didn't appear to time-out with a full queue")
130 except self.queue.Full:
141 self.fail("Didn't appear to block with an empty queue")
142 except self.queue.Empty:
146 self.fail("Didn't appear to time-out with an empty queue")
147 except self.queue.Empty:
183 # Test to make sure a queue task completed successfully.
193 # Test that a queue join()s successfully, and before anything else
206 # Do it a couple of times on the same queue.
223 with self.assertRaises(self.queue.Full):
228 with self.assertRaises(self.queue.Empty):
237 with self.assertRaises(self.queue.Full):
240 q.maxsize = 2 # shrink the queue
241 with self.assertRaises(self.queue.Full):
247 self.type2test = self.queue.Queue
251 queue = py_queue
256 queue = c_queue
262 self.type2test = self.queue.LifoQueue
267 queue = py_queue
272 queue = c_queue
278 self.type2test = self.queue.PriorityQueue
283 queue = py_queue
288 queue = c_queue
299 Queue = self.queue.Queue
323 raise RuntimeError("Call this function with an empty queue")
330 self.fail("The queue didn't fail when it should have")
336 self.fail("The queue didn't fail when it should have")
345 self.fail("The queue didn't fail when it should have")
356 self.fail("The queue didn't fail when it should have")
377 self.fail("The queue didn't fail when it should have")
384 self.fail("The queue didn't fail when it should have")
394 self.fail("The queue didn't fail when it should have")
404 # Test to make sure a queue is functioning correctly.
413 queue = py_queue
418 queue = c_queue
449 except self.queue.Empty:
462 except self.queue.Empty:
530 with self.assertRaises(self.queue.Empty):
532 with self.assertRaises(self.queue.Empty):
534 with self.assertRaises(self.queue.Empty):
586 # The queue should lose references to each item as soon as
587 # it leaves the queue.
603 queue = py_queue
605 self.type2test = self.queue._PySimpleQueue
612 queue = c_queue
615 self.type2test = self.queue.SimpleQueue
619 self.assertIs(self.type2test, self.queue.SimpleQueue)
620 self.assertIs(self.type2test, self.queue.SimpleQueue)