agronholm / agronholm/pythonfutures
[Errno 32] Broken pipe When Mapping Too Many Values
- Linguagem predominante
- Python
- Estrelas
- 236
- Forks
- 46
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Descrição
First of all, thanks for that great backport. I am using it for the xfork package to support the 2.7 branch.
Unfortunately, there is something strange happening with this futures distribution which works perfectly fine with python3.4
```
from concurrent.futures import ProcessPoolExecutor
def calc(n):
with ProcessPoolExecutor() as pool:
results = pool.map(term, range(n))
return sum(results)
def term(x):
return x
print(calc(5000))
```
```
/usr/bin/python2.7 calc.py
12497500
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/queues.py", line 266, in _feed
send(obj)
IOError: [Errno 32] Broken pipe
```
Guia de contribuição
Nenhum guia de contribuição indexado para este repositório
Avaliação
Esta issue ainda não foi avaliada.