Lines Matching defs:Queue
6 import queue as pyqueue
234 q = self.Queue(1)
521 def _test_put(cls, queue, child_can_start, parent_can_continue):
524 queue.get()
529 queue = self.Queue(maxsize=MAXSIZE)
535 args=(queue, child_can_start, parent_can_continue)
540 self.assertEqual(queue_empty(queue), True)
541 self.assertEqual(queue_full(queue, MAXSIZE), False)
543 queue.put(1)
544 queue.put(2, True)
545 queue.put(3, True, None)
546 queue.put(4, False)
547 queue.put(5, False, None)
548 queue.put_nowait(6)
553 self.assertEqual(queue_empty(queue), False)
554 self.assertEqual(queue_full(queue, MAXSIZE), True)
556 put = TimingWrapper(queue.put)
557 put_nowait = TimingWrapper(queue.put_nowait)
580 self.assertEqual(queue_empty(queue), True)
581 self.assertEqual(queue_full(queue, MAXSIZE), False)
586 def _test_get(cls, queue
588 #queue.put(1)
589 queue.put(2)
590 queue.put(3)
591 queue.put(4)
592 queue.put(5)
596 queue = self.Queue()
602 args=(queue, child_can_start, parent_can_continue)
607 self.assertEqual(queue_empty(queue), True)
613 self.assertEqual(queue_empty(queue), False)
616 #self.assertEqual(queue.get(), 1)
617 self.assertEqual(queue.get(True, None), 2)
618 self.assertEqual(queue.get(True), 3)
619 self.assertEqual(queue.get(timeout=1), 4)
620 self.assertEqual(queue.get_nowait(), 5)
622 self.assertEqual(queue_empty(queue), True)
624 get = TimingWrapper(queue.get)
625 get_nowait = TimingWrapper(queue.get_nowait)
648 def _test_fork(cls, queue):
650 queue.put(i)
656 # Old versions of Queue would fail to create a new feeder
661 queue = self.Queue()
663 # put items on queue so that main process starts a feeder thread
665 queue.put(i)
671 p = self.Process(target=self._test_fork, args=(queue,))
675 # check that all expected items are in the queue
677 self.assertEqual(queue.get(), i)
678 self.assertRaises(pyqueue.Empty, queue.get, False)
683 q = self.Queue()
704 queue = self.JoinableQueue()
706 workers = [self.Process(target=self._test_task_done, args=(queue,))
714 queue.put(i)
716 queue.join()
719 queue.put(None)
731 q = multiprocessing.Queue()
746 q = multiprocessing.Queue()
1261 def _test_wait_return_f(cls, barrier, queue):
1263 queue.put(res)
1269 queue = self.Queue()
1270 self.run_threads(self._test_wait_return_f, (self.barrier, queue))
1271 results = [queue.get() for i in range(self.N)]
1986 # process would fill the result queue (after the result handler thread
2183 _queue = pyqueue.Queue()
2214 queue = manager.get_queue()
2216 queue.put(tuple(cls.values))
2234 queue = manager2.get_queue()
2236 self.assertEqual(queue.get(), self.result)
2240 self.assertRaises(Exception, queue.put, time.sleep)
2242 # Make queue finalizer run before the server is stopped
2243 del queue
2253 queue = manager.get_queue()
2254 queue.put('hello world')
2270 queue = manager.get_queue()
2271 self.assertEqual(queue.get(), 'hello world')
2272 del queue
3267 queue = multiprocessing.Queue()
3268 subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
3306 queue = multiprocessing.Queue()
3307 proc = multiprocessing.Process(target=_test_process, args=(queue,))
3887 Queue = staticmethod(multiprocessing.Queue)
3905 Queue = property(operator.attrgetter('manager.Queue'))
3957 Queue = staticmethod(multiprocessing.dummy.Queue)
