diff options
author | Christian Heimes <christian@cheimes.de> | 2013-10-13 02:22:10 +0200 |
---|---|---|
committer | Christian Heimes <christian@cheimes.de> | 2013-10-13 02:22:10 +0200 |
commit | 06239f62b0dd6201f1c5ffde1be1e359fae662a6 (patch) | |
tree | 239e0e3e01aff5c1de70d61892d690be48024f20 | |
parent | bf235bd212d0c420c7fd78dcb1baea69c48e6552 (diff) | |
parent | 7b4a36194af5942d3a497cecc1cc0cae8f3e00fd (diff) | |
download | cpython-git-06239f62b0dd6201f1c5ffde1be1e359fae662a6.tar.gz |
merge
-rw-r--r-- | Lib/test/_test_multiprocessing.py | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/Lib/test/_test_multiprocessing.py b/Lib/test/_test_multiprocessing.py index de0c968923..0324afa7ae 100644 --- a/Lib/test/_test_multiprocessing.py +++ b/Lib/test/_test_multiprocessing.py @@ -273,7 +273,7 @@ class _TestProcess(BaseTestCase): @classmethod def _test_terminate(cls): - time.sleep(1000) + time.sleep(100) def test_terminate(self): if self.TYPE == 'threads': @@ -299,7 +299,19 @@ class _TestProcess(BaseTestCase): p.terminate() - self.assertEqual(join(), None) + if hasattr(signal, 'alarm'): + def handler(*args): + raise RuntimeError('join took too long: pid=%s' % p.pid) + old_handler = signal.signal(signal.SIGALRM, handler) + try: + signal.alarm(10) + self.assertEqual(join(), None) + signal.alarm(0) + finally: + signal.signal(signal.SIGALRM, old_handler) + else: + self.assertEqual(join(), None) + self.assertTimingAlmostEqual(join.elapsed, 0.0) self.assertEqual(p.is_alive(), False) |