Fix issue #17707: multiprocessing.Queue's get() method does not block for short timeouts.

This commit is contained in:
Giampaolo Rodola' 2013-04-17 13:12:27 +02:00
parent 22b9e651c2
commit 308307190f
3 changed files with 11 additions and 1 deletions

View file

@ -699,6 +699,13 @@ class _TestQueue(BaseTestCase):
for p in workers:
p.join()
def test_timeout(self):
q = multiprocessing.Queue()
start = time.time()
self.assertRaises(pyqueue.Empty, q.get, True, 0.2)
delta = time.time() - start
self.assertGreaterEqual(delta, 0.19)
#
#
#