(self)
| 17 | super().__init__(daemon=True) |
| 18 | |
| 19 | def run(self): |
| 20 | while True: |
| 21 | self._event.wait() |
| 22 | if self._exit: |
| 23 | break |
| 24 | sleep(self._sleep_time) |
| 25 | self._event.clear() |
| 26 | # self.future.set_result(None) |
| 27 | assert self.future is not None |
| 28 | self._loop.call_soon_threadsafe(self.future.set_result, None) |
| 29 | |
| 30 | async def sleep(self, sleep_time: float) -> None: |
| 31 | future = self.future = self._loop.create_future() |