(self, work_queue, result_queue)
| 93 | self.active_workers.value -= 1 |
| 94 | |
| 95 | def launch(self, work_queue, result_queue): |
| 96 | for worker_id in range(self.args.workers): |
| 97 | p = multiprocessing.Process(target=self.worker, args=(work_queue, result_queue, worker_id)) |
| 98 | p.start() |
| 99 | self.workers.append(p) |
| 100 | |
| 101 | def terminate(self): |
| 102 | for worker in self.workers: |