(self)
| 15475 | self.worker.start() |
| 15476 | |
| 15477 | def close(self) -> None: |
| 15478 | with self.condition: |
| 15479 | self.closed = True |
| 15480 | self.condition.notify_all() |
| 15481 | self.worker.join() |
| 15482 | self.scheduler.close() |
| 15483 | |
| 15484 | def enqueue(self, command: Callable[[], None]) -> None: |
| 15485 | with self.condition: |