David Lukeš <dafydd.lu...@gmail.com> added the comment:

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.

----------

_______________________________________
Python tracker <rep...@bugs.python.org>
<https://bugs.python.org/issue32306>
_______________________________________
_______________________________________________
Python-bugs-list mailing list
Unsubscribe: 
https://mail.python.org/mailman/options/python-bugs-list/archive%40mail-archive.com

Reply via email to