Message308720
Hi Antoine,
Thanks for the response! :) I think the problem lies in the line immediately preceding the code you've posted:
```
fs = [self.submit(fn, *args) for args in zip(*iterables)]
```
In other words, all the jobs are first submitted and their futures stored in a list, which is then iterated over. This approach obviously breaks down when there is a great number of jobs, or when it's part of a pipeline meant for processing jobs continuously as they come. |
|
Date |
User |
Action |
Args |
2017-12-20 11:21:24 | dlukes | set | recipients:
+ dlukes, pitrou, docs@python |
2017-12-20 11:21:24 | dlukes | set | messageid: <1513768884.04.0.213398074469.issue32306@psf.upfronthosting.co.za> |
2017-12-20 11:21:24 | dlukes | link | issue32306 messages |
2017-12-20 11:21:23 | dlukes | create | |
|