Initial commit

Author: YvesDup

Lib/multiprocessing/synchronize.py

@@ -91,7 +91,9 @@ def _make_methods(self):
         self.release = self._semlock.release
 
     def locked(self):
-        return self._semlock._count() != 0
+        '''Return True if SemLock is acquired.
+        '''
+        return self._semlock._is_zero()
 
     def __enter__(self):
         return self._semlock.__enter__()

Lib/test/_test_multiprocessing.py

@@ -1492,6 +1492,25 @@ def test_lock(self):
         self.assertFalse(lock.locked())
         self.assertRaises((ValueError, threading.ThreadError), lock.release)
 
+    @classmethod
+    def _test_lock_locked_2processes(cls, lock, event):
+        lock.acquire()
+        event.set()
+
+    def test_lock_locked_2processes(self):
+        if self.TYPE != 'processes':
+            self.skipTest('test not appropriate for {}'.format(self.TYPE))
+
+        lock = self.Lock()
+        event = self.Event()
+        p = self.Process(target=self._test_lock_locked_2processes,
+                         args=(lock, event))
+        p.start()
+        event.wait()
+        self.assertTrue(lock.locked())
+        p.join()
+        print(lock, event)
+
     @staticmethod
     def _acquire_release(lock, timeout, l=None, n=1):
         for _ in range(n):
@@ -1561,6 +1580,20 @@ def test_rlock(self):
         self.assertFalse(lock.locked())
         self.assertRaises((AssertionError, RuntimeError), lock.release)
 
+    def test_rlock_locked_2processes(self):
+        if self.TYPE != 'processes':
+            self.skipTest('test not appropriate for {}'.format(self.TYPE))
+
+        rlock = self.RLock()
+        event = self.Event()
+        # target is the same as for the test_lock_locked_2processes test.
+        p = self.Process(target=self._test_lock_locked_2processes,
+                         args=(rlock, event))
+        p.start()
+        event.wait()
+        self.assertTrue(rlock.locked())
+        p.join()
+
     def test_lock_context(self):
         with self.Lock() as locked:
             self.assertTrue(locked)