agronholm / agronholm/pythonfutures

[Errno 32] Broken pipe When Mapping Too Many Values

Aperta
#47 6 commenti 2 reazioni 0 assegnatari Vedi su GitHub
awaiting input
Lingua principale
Python
Stelle
236
Fork
46
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

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
```

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Valutazione

Questa issue non è ancora stata valutata.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.