(self, worker_count)
| 507 | |
| 508 | class ThreadPool(object): |
| 509 | def __init__(self, worker_count): |
| 510 | self.workers = [] |
| 511 | self.work_queue = Queue() |
| 512 | |
| 513 | for _ in range(worker_count): |
| 514 | w = Thread(target = self.worker, daemon=True) |
| 515 | w.start() |
| 516 | self.workers.append(w) |
| 517 | |
| 518 | def worker(self): |
| 519 | func, args, future = self.work_queue.get() |