agronholm / agronholm/pythonfutures

[Errno 32] Broken pipe When Mapping Too Many Values

Offen
#47 6 Kommentare 2 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
awaiting input
Vorherrschende Sprache
Python
Sterne
236
Forks
46
PR-Merge-Kennzahlen
Keine gemergten PRs in 30 T.

Beschreibung

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

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.