agronholm / agronholm/pythonfutures

[Errno 32] Broken pipe When Mapping Too Many Values

Abierto
#47 6 comentarios 2 reacciones 0 asignados Ver en GitHub
awaiting input
Lenguaje dominante
Python
Estrellas
236
Forks
46
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

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

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.