From: Richard Oudkerk <shibturn@gmail.com>
Date: Tue, 5 Jun 2012 12:15:29 +0000 (+0100)
Subject: Add test for multiprocessing.Conditon.wait() and changset 3baeb5e13dd2
X-Git-Tag: v3.3.0b1~268
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=9844993cde5d8572d8e611d8b437a2e45e841414;p=python

Add test for multiprocessing.Conditon.wait() and changset 3baeb5e13dd2
---

diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py
index f02041ebf2..78cbdacd8f 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):