(inqueue, task_handler, size)
| 670 | |
| 671 | @staticmethod |
| 672 | def _help_stuff_finish(inqueue, task_handler, size): |
| 673 | # task_handler may be blocked trying to put items on inqueue |
| 674 | util.debug('removing tasks from inqueue until task handler finished') |
| 675 | inqueue._rlock.acquire() |
| 676 | while task_handler.is_alive() and inqueue._reader.poll(): |
| 677 | inqueue._reader.recv() |
| 678 | time.sleep(0) |
| 679 | |
| 680 | @classmethod |
| 681 | def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, change_notifier, |