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