Better understanding of where this went wrong internally

Author: mikeshardmind

_misc/_l.py

@@ -17,7 +17,10 @@ async def check(lock: AsyncLock):
 
 async def amain():
     lock = AsyncLock()
-    with threaded_loop() as tl1, threaded_loop() as tl2:
+    with (
+        threaded_loop(use_eager_task_factory=False) as tl1,
+        threaded_loop(use_eager_task_factory=False) as tl2,
+    ):
         tsks = {loop.run(check(lock)) for loop in (tl1, tl2) for _ in range(10)}
         await asyncio.gather(*tsks)
 

src/async_utils/_simple_lock.py

@@ -41,8 +41,11 @@ def __locked(self) -> bool:
             return self._lockv or (any(not w.cancelled() for w in (self._waiters)))
 
     async def __aenter__(self) -> None:
-        await asyncio.sleep(0)  # This yield is non-optional.
+        # placing the body of acquire here
+        # causes problems with eager tasks factories.
+        await self.__acquire()
 
+    async def __acquire(self) -> None:
         with self._internal_lock:
             if not self.__locked():
                 self._lockv = True
@@ -80,7 +83,6 @@ def _maybe_wake(self) -> None:
                     break
 
     async def __aexit__(self, *dont_care: object) -> t.Literal[False]:
-        await asyncio.sleep(0)  # this yield is not optional
         with self._internal_lock:
             self._lockv = False
             self._maybe_wake()