(self, gen)
| 293 | raise Exception('Internal error in a worker process.') |
| 294 | |
| 295 | def _advance_more(self, gen): |
| 296 | while self.processing_count < self.num_workers * self.BUFFER_FACTOR: |
| 297 | try: |
| 298 | self.work_queue.put(next(gen)) |
| 299 | self.processing_count += 1 |
| 300 | except StopIteration: |
| 301 | self.advance = self._advance_empty |
| 302 | break |
| 303 | |
| 304 | def _advance_empty(self, gen): |
| 305 | pass |