Lines Matching refs:get

291                 child_args = q.get()
406         self.assertEqual(q.get(), args[1:])
407         self.assertEqual(q.get(), kwargs)
408         self.assertEqual(q.get(), p.name)
410             self.assertEqual(q.get(), current.authkey)
411             self.assertEqual(q.get(), p.pid)
431         child_mainthread_native_id = q.get()
586             q.get()
666         self.assertEqual(q.get(), 5)
696             fd_counts = [q.get() for i in range(N)]
964             queue.get()
1057         #self.assertEqual(queue.get(), 1)
1058         self.assertEqual(queue.get(True, None), 2)
1059         self.assertEqual(queue.get(True), 3)
1060         self.assertEqual(queue.get(timeout=1), 4)
1065         get = TimingWrapper(queue.get)
1068         self.assertRaises(pyqueue.Empty, get, False)
1069         self.assertTimingAlmostEqual(get.elapsed, 0)
1071         self.assertRaises(pyqueue.Empty, get, False, None)
1072         self.assertTimingAlmostEqual(get.elapsed, 0)
1077         self.assertRaises(pyqueue.Empty, get, True, TIMEOUT1)
1078         self.assertTimingAlmostEqual(get.elapsed, TIMEOUT1)
1080         self.assertRaises(pyqueue.Empty, get, False, TIMEOUT2)
1081         self.assertTimingAlmostEqual(get.elapsed, 0)
1083         self.assertRaises(pyqueue.Empty, get, timeout=TIMEOUT3)
1084         self.assertTimingAlmostEqual(get.elapsed, TIMEOUT3)
1119             self.assertEqual(queue.get(), i)
1120         self.assertRaises(pyqueue.Empty, queue.get, False)
1135         q.get()
1137         q.get()
1143         for obj in iter(q.get, None):
1178                     q.get(timeout=3)
1193         self.assertRaises(pyqueue.Empty, q.get, True, 0.200)
1213             self.assertTrue(q.get(timeout=support.SHORT_TIMEOUT))
1228             self.assertTrue(q.get(timeout=support.SHORT_TIMEOUT))
1265             self.assertTrue(q.get(timeout=support.SHORT_TIMEOUT))
1277                 q.get()
1883         results = [queue.get() for i in range(self.N)]
2357         self.assertEqual(a[0].get(), 123)
2361         self.assertEqual(b[0].get(), 456)
2449         self.assertEqual(self.pool.starmap_async(mul, tuples).get(),
2453         self.assertEqual(self.pool.map_async(sqr, list(range(10))).get(),
2481             self.pool.map_async(sqr, [], chunksize=1).get(timeout=TIMEOUT1)
2513         get = TimingWrapper(res.get)
2514         self.assertEqual(get(), 49)
2515         self.assertTimingAlmostEqual(get.elapsed, TIMEOUT1)
2519         get = TimingWrapper(res.get)
2520         self.assertRaises(multiprocessing.TimeoutError, get, timeout=TIMEOUT2)
2521         self.assertTimingAlmostEqual(get.elapsed, TIMEOUT2)
2638         self.assertEqual(p.map_async(sqr, []).get(), [])
2649                 self.assertEqual(r.get(), expected)
2790         self.assertRaises(KeyError, res.get)
2809             self.assertRaises(MaybeEncodingError, res.get)
2833             self.assertEqual(res.get(), sqr(j))
2862             self.assertEqual(res.get(), sqr(j))
3033         self.assertEqual(queue.get(), self.result)
3072             self.assertEqual(queue.get(), 'hello world')
3686         # get the heap object
4156         # Index Out of Range (get)
4448                     # Old Foo's get gradually replaced and later
4712         item = q.get(block=False)
5052     # after fork registry would get duplicate entries for the same
5480         self.assertEqual(queue.get(), True)
5481         self.assertEqual(queue.get(), False)
5689         assert obj.get() == 5
5691         assert obj.get() == 6
5728         assert obj.get('foo') == 5
5745         assert obj.get() == 1
5752         self.assertEqual(o.get(), 2)
6014         # pause a bit so we don't get warning about dangling threads/processes