(self)
| 308 | self._fork_invalidated = True |
| 309 | |
| 310 | def __del__(self) -> None: |
| 311 | # Safety net when close() was never called: shut down the executor we own so its worker thread does not |
| 312 | # outlive the lock. shutdown(wait=False) never blocks. |
| 313 | if os.getpid() == getattr(self, "_creator_pid", None) and getattr(self, "_owns_executor", False): |
| 314 | self._executor.shutdown(wait=False) |
| 315 | |
| 316 | |
| 317 | class AsyncAcquireReadWriteReturnProxy: |
nothing calls this directly
no outgoing calls
no test coverage detected