Initial commit

Author: YvesDup

Lib/test/_test_multiprocessing.py

@@ -1496,6 +1496,12 @@ def _acquire_release(lock, timeout, l=None, n=1):
         for _ in range(n):
             lock.release()
 
+    @staticmethod
+    def _acquire_and_wait(lock, barrier, timeout=.1):
+        lock.acquire()
+        barrier.wait()
+        time.sleep(timeout)
+
     def test_repr_rlock(self):
         if self.TYPE != 'processes':
             self.skipTest('test not appropriate for {}'.format(self.TYPE))
@@ -1521,14 +1527,14 @@ def test_repr_rlock(self):
         for i in range(n):
             self.assertIn(f'<RLock(MainProcess|T{i+1}, {i+1})>', l)
 
-
-        t = threading.Thread(target=self._acquire_release,
-                                 args=(lock, 0.2),
-                                 name=f'T1')
+        rlock = self.RLock()
+        barrier = self.Barrier(2)
+        t = threading.Thread(target=self._acquire_and_wait,
+                             args=(rlock, barrier, .2))
         t.start()
-        time.sleep(0.1)
-        self.assertEqual('<RLock(SomeOtherThread, nonzero)>', repr(lock))
-        time.sleep(0.2)
+        barrier.wait()
+        self.assertEqual('<RLock(SomeOtherThread, nonzero)>', repr(rlock))
+        t.join()
 
         pname = 'P1'
         l = multiprocessing.Manager().list()
@@ -1539,12 +1545,12 @@ def test_repr_rlock(self):
         p.join()
         self.assertEqual(f'<RLock({pname}, 1)>', l[0])
 
-        event = self.Event()
+        barrier = self.Barrier(2)
         lock = self.RLock()
-        p = self.Process(target=self._acquire_event,
-                         args=(lock, event))
+        p = self.Process(target=self._acquire_and_wait,
+                         args=(lock, barrier, .2))
         p.start()
-        event.wait()
+        barrier.wait()
         self.assertEqual('<RLock(SomeOtherProcess, nonzero)>', repr(lock))
         p.join()