diff options
| author | Giampaolo Rodola' <g.rodola@gmail.com> | 2013-04-17 13:08:59 +0200 |
|---|---|---|
| committer | Giampaolo Rodola' <g.rodola@gmail.com> | 2013-04-17 13:08:59 +0200 |
| commit | b38897fc91c7f4b80bc2025ade219674d7b78bf3 (patch) | |
| tree | e57827847e0cfc3fde489a7938576ad9b049fb49 /Lib/test/test_multiprocessing.py | |
| parent | 643ea53c140e2d2b3e21197fd87c1778131297d0 (diff) | |
| download | cpython-git-b38897fc91c7f4b80bc2025ade219674d7b78bf3.tar.gz | |
Fix issue #17707: multiprocessing.Queue's get() method does not block for short timeouts.
Diffstat (limited to 'Lib/test/test_multiprocessing.py')
| -rw-r--r-- | Lib/test/test_multiprocessing.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index 3fb07f6a54..14ec61c393 100644 --- a/Lib/test/test_multiprocessing.py +++ b/Lib/test/test_multiprocessing.py @@ -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) + # # # |