(self, base_path: Path)
| 10 | class FileWriterProcess(Process): |
| 11 | |
| 12 | def __init__(self, base_path: Path): |
| 13 | super().__init__() |
| 14 | self._input_queue_2d = Queue2D() |
| 15 | self._input_queue_3d = Queue3D() |
| 16 | self._exit_event = Event() |
| 17 | self._base_path = base_path |
| 18 | os.makedirs(self._base_path, exist_ok=True) |
| 19 | self.daemon = True |
| 20 | |
| 21 | def stop(self): |
| 22 | self._exit_event.set() |