Merge pull request #21 from Joshuaalbert/develop

Develop
Joshuaalbert · Oct 16, 2024 · 7c3ed4e · 7c3ed4e
2 parents bad409d + d1299ec
commit 7c3ed4e
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/.github/workflows/unittests.yml b/.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

diff --git a/fair_async_rlock/fair_async_rlock.py b/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()

diff --git a/fair_async_rlock/tests/test_fair_async_rlock.py b/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()