diff options
| author | sobolevn <mail@sobolevn.me> | 2025-04-08 08:14:12 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-04-08 08:14:12 (GMT) |
| commit | f7305a06c7a322d23b39ad9d16af814d467624c6 (patch) | |
| tree | 8a25dede6c059e01ae98c63d737ac0d0c1987b58 /Modules/_threadmodule.c | |
| parent | 6cd1d6c6b142697fb72f422b7b448c27ebc30534 (diff) | |
| download | cpython-f7305a06c7a322d23b39ad9d16af814d467624c6.zip cpython-f7305a06c7a322d23b39ad9d16af814d467624c6.tar.gz cpython-f7305a06c7a322d23b39ad9d16af814d467624c6.tar.bz2 | |
gh-115942: Add `locked` to several multiprocessing locks (#115944)
Co-authored-by: mpage <mpage@cs.stanford.edu>
Co-authored-by: Hugo van Kemenade <1324225+hugovk@users.noreply.github.com>
Diffstat (limited to 'Modules/_threadmodule.c')
| -rw-r--r-- | Modules/_threadmodule.c | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/Modules/_threadmodule.c b/Modules/_threadmodule.c index f4c98ca..9f6ac21 100644 --- a/Modules/_threadmodule.c +++ b/Modules/_threadmodule.c @@ -1087,6 +1087,19 @@ PyDoc_STRVAR(rlock_exit_doc, 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); + return PyBool_FromLong(is_locked); +} + +PyDoc_STRVAR(rlock_locked_doc, +"locked()\n\ +\n\ +Return a boolean indicating whether this object is locked right now."); + +static PyObject * rlock_acquire_restore(PyObject *op, PyObject *args) { rlockobject *self = rlockobject_CAST(op); @@ -1204,6 +1217,8 @@ static PyMethodDef rlock_methods[] = { METH_VARARGS | METH_KEYWORDS, rlock_acquire_doc}, {"release", rlock_release, METH_NOARGS, rlock_release_doc}, + {"locked", rlock_locked, + METH_NOARGS, rlock_locked_doc}, {"_is_owned", rlock_is_owned, METH_NOARGS, rlock_is_owned_doc}, {"_acquire_restore", rlock_acquire_restore, |