| 336 | self.nr_producer = nr_producer |
| 337 | |
| 338 | def run(self): |
| 339 | nr_end = 0 |
| 340 | try: |
| 341 | while True: |
| 342 | task_id, data = self.data_queue.get() |
| 343 | if task_id == DIE: |
| 344 | self.result_queue.put((task_id, data)) |
| 345 | nr_end += 1 |
| 346 | if nr_end == self.nr_producer: |
| 347 | return |
| 348 | else: |
| 349 | self.ordered_container.put(task_id, data) |
| 350 | while self.ordered_container.has_next(): |
| 351 | self.result_queue.put(self.ordered_container.get()) |
| 352 | except Exception as e: |
| 353 | import traceback |
| 354 | traceback.print_exc() |
| 355 | raise e |
| 356 | |
| 357 | def get(self): |
| 358 | return self.result_queue.get() |