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:08:59 +02:00
parent 643ea53c14
commit b38897fc91
3 changed files with 11 additions and 1 deletions

View file

@ -698,6 +698,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)
#
#
#