Initial commit

Author: YvesDup

Lib/test/lock_tests.py

@@ -370,6 +370,19 @@ def test_locked(self):
         lock.release()
         self.assertFalse(lock.locked())
 
+    def test_locked_2threads(self):
+        l = []
+        rlock = self.locktype()
+        def acquire():
+            rlock.acquire()
+            l.append(rlock.locked())
+
+        with Bunch(acquire, 1):
+            pass
+        self.assertTrue(rlock.locked())
+        self.assertTrue(l[0])
+        del rlock
+
     def test_release_save_unacquired(self):
         # Cannot _release_save an unacquired lock
         lock = self.locktype()

Lib/threading.py

@@ -237,7 +237,7 @@ def __exit__(self, t, v, tb):
 
     def locked(self):
         """Return whether this object is locked."""
-        return self._count > 0
+        return self._block.locked()
 
     # Internal methods used by condition variables
 

Modules/_threadmodule.c

@@ -1110,8 +1110,12 @@ Release the lock.");
 static PyObject *
 rlock_locked(PyObject *op, PyObject *Py_UNUSED(ignored))
 {
-    rlockobject *self = rlockobject_CAST(op);
-    int is_locked = _PyRecursiveMutex_IsLockedByCurrentThread(&self->lock);
+    /*
+    see gh-134323: the `_PyRecursiveMutex_IsLocked` function does not exist, so we cast the `op`
+    to `lockobject` in order to call `PyMutex_IsLocked`.
+    */
+    lockobject *self = lockobject_CAST(op);
+    int is_locked = PyMutex_IsLocked(&self->lock);
     return PyBool_FromLong(is_locked);
 }