(self, use_blocking_lock=True)
| 90 | self._stop(use_blocking_lock=False) |
| 91 | |
| 92 | def _stop(self, use_blocking_lock=True): |
| 93 | if use_blocking_lock: |
| 94 | with self._lock: |
| 95 | self._stop_locked() |
| 96 | else: |
| 97 | acquired = self._lock.acquire(blocking=False) |
| 98 | try: |
| 99 | self._stop_locked() |
| 100 | finally: |
| 101 | if acquired: |
| 102 | self._lock.release() |
| 103 | |
| 104 | def _stop_locked( |
| 105 | self, |