Develop

.github/workflows/unittests.yml

@@ -16,7 +16,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: [ "3.7", "3.8", "3.9", "3.10", "3.11" ]
+        python-version: [ "3.7", "3.8", "3.9", "3.10", "3.11", "3.12" ]
 
     steps:
       - uses: actions/checkout@v3

fair_async_rlock/fair_async_rlock.py

@@ -22,6 +22,9 @@ def is_owner(self, task=None):
             task = asyncio.current_task()
         return self._owner == task
 
+    def locked(self) -> bool:
+        return self._owner is not None
+
     async def acquire(self):
         """Acquire the lock."""
         me = asyncio.current_task()

fair_async_rlock/tests/test_fair_async_rlock.py

@@ -652,3 +652,13 @@ async def task3():
     t3 = asyncio.create_task(task3())
 
     await asyncio.gather(t1, t2, t3)
+
+@pytest.mark.asyncio
+def test_locked():
+    lock = FairAsyncRLock()
+    assert not lock.locked()
+    async def task():
+        async with lock:
+            assert lock.locked()
+    asyncio.run(task())
+    assert not lock.locked()