import randomtime
from collections import deque
from itertools import islice
from concurrent.futures import ProcessPoolExecutor, ThreadPoolExecutor, as_completed
def fact(n):
res = 1
for i in range(2, n+1):
res *= i
return res
if __name__ == "__main__":
with ProcessPoolExecutor() as e:
# metemos 1000 procesos
futuresfs1 = { e.submit(fact, i):i
for i in (random.randrange(10000) for x in range(1000)) }
print("Lanzados 1000 futuros")
# obtenemos los primeros 10 resultados
res10 = { futures[f]fs1[f]:f.result() for f in islice(as_completed(futuresfs1), 10)}
# metemos otros 1000100000 más
futures2fs2 = { e.submit(fact, i):i
for i in range(1000, 100000) }
for i in (random.randrangeprint(10000) for"Lanzados x100000 infuturos range(1000)más") }
# obtenemos los siguientes 10 resultados de la segunda tanda
res20 = { futures2[f]fs2[f]:f.result() for f in islice(as_completed(futures2fs2), 101000, 1010)}
# obtenemos los últimos 10 resultados de la tanda anterior
res30 = { futures[f]fs1[f]:f.result() for f in deque(as_completed(futuresfs1), 10)}
# salimosEspera delpara contextocomprobar cómo sube el consumo de ejecución,CPU
con lo print("Espera de 3 segundos")
# que terminan time.sleep(3)
# Cancelamos todos los procesos que no hayan acabado de la segunda tanda
for f in fs2:
f.cancel()
print("Cierre del ejecutor de procesos")
print()
for (n,res) in res10.items():
print(f"fact({n:4d})) = {str(res)[:80]}...")
print()
for (n,res) in res20.items():
print(f"fact({n:4d})) = {str(res)[:80]}...")
print()
for (n,res) in res30.items():
print(f"fact({n:4d})) = {str(res)[:80]}...")
Edición: he simplificado el código para que se entienda algo mejor.