From 9844993cde5d8572d8e611d8b437a2e45e841414 Mon Sep 17 00:00:00 2001 From: Richard Oudkerk Date: Tue, 5 Jun 2012 13:15:29 +0100 Subject: [PATCH] Add test for multiprocessing.Conditon.wait() and changset 3baeb5e13dd2 --- Lib/test/test_multiprocessing.py | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index f02041ebf29..78cbdacd8f6 100644 --- a/Lib/test/test_multiprocessing.py +++ b/Lib/test/test_multiprocessing.py @@ -956,6 +956,34 @@ class _TestCondition(BaseTestCase): p.join(5) self.assertTrue(success.value) + @classmethod + def _test_wait_result(cls, c, pid): + with c: + c.notify() + time.sleep(1) + if pid is not None: + os.kill(pid, signal.SIGINT) + + def test_wait_result(self): + if isinstance(self, ProcessesMixin) and sys.platform != 'win32': + pid = os.getpid() + else: + pid = None + + c = self.Condition() + with c: + self.assertFalse(c.wait(0)) + self.assertFalse(c.wait(0.1)) + + p = self.Process(target=self._test_wait_result, args=(c, pid)) + p.start() + + self.assertTrue(c.wait(10)) + if pid is not None: + self.assertRaises(KeyboardInterrupt, c.wait, 10) + + p.join() + class _TestEvent(BaseTestCase):