(self, task, *args, **kwargs)
| 345 | self.start_workers() |
| 346 | |
| 347 | def add_task(self, task, *args, **kwargs): |
| 348 | args = args or () |
| 349 | kwargs = kwargs or {} |
| 350 | self.put((task, args, kwargs)) |
| 351 | |
| 352 | def start_workers(self): |
| 353 | for _ in range(self.num_workers): |