(self)
| 121 | signal.signal(sig, lambda sig, frame: self.signal_queue.append(sig)) |
| 122 | |
| 123 | def init_processes(self) -> None: |
| 124 | for _ in range(self.processes_num): |
| 125 | process = Process(self.config, self.target, self.sockets) |
| 126 | process.start() |
| 127 | self.processes.append(process) |
| 128 | |
| 129 | def terminate_all(self) -> None: |
| 130 | for process in self.processes: |