(self, path, rank)
| 5 | |
| 6 | class _Writer: |
| 7 | def __init__(self, path, rank): |
| 8 | self.msg_queue = multiprocessing.Queue() |
| 9 | self.worker = multiprocessing.Process( |
| 10 | target=self._async_manager_worker_fn, |
| 11 | args=(self.msg_queue, path, rank), |
| 12 | ) |
| 13 | self.worker.start() |
| 14 | |
| 15 | def write(self, key: str, value: bytes) -> bool: |
| 16 | self.msg_queue.put((key, value)) |