(self)
| 42 | self.send_process = mp.Process(target=self.send_worker, args=(out_port, self.send_queue, self.worker_alive)) |
| 43 | |
| 44 | def run(self): |
| 45 | self.worker_alive.value = 1 |
| 46 | |
| 47 | self.recv_process.start() |
| 48 | self.predictor_process.start() |
| 49 | self.send_process.start() |
| 50 | |
| 51 | try: |
| 52 | self.recv_process.join() |
| 53 | self.predictor_process.join() |
| 54 | self.send_process.join() |
| 55 | except KeyboardInterrupt: |
| 56 | pass |
| 57 | |
| 58 | @staticmethod |
| 59 | def recv_worker(port, recv_queue, worker_alive): |