Cuando esto se ejecuta, podemos ver que los futuros para A, B y C se ejecutan al mismo tiempo. pero D debe esperar hasta que uno de los otros termine: A partir de… ABCACBCABCBABCACBACABCBACABCBADDDDDDDD futuro4.resultado(): 9 Todo listo El subproceso principal también espera a que future4 finalice, ya que solicita el resultado que es una llamada de bloqueo que solo regresará una vez que el futuro se haya completado y genere una resultado. Nuevamente, para usar Procesos en lugar de Subprocesos, todo lo que tenemos que hacer es reemplazar el ThreadPoolExecutor con ProcessPoolExecutor: de concurrent.futures import ProcessPoolExecutor imprimir(‘Iniciando…’) grupo = ProcessPoolExecutor(3) futuro1 = pool.submit(trabajador, ‘A’) futuro2 = pool.submit(trabajador, ‘B’) futuro3 = pool.submit(trabajador, ‘C’) future4 = pool.submit(trabajador, ‘D’) print(’\nfuturo4.resultado():’, futuro4.resultado()) imprimir(‘Todo Listo’) 33.4.1 Esperando a que se completen todos los futuros Es posible esperar a que se completen todos los futuros antes de avanzar. En el anterior sección se supuso que future4 sería el último futuro en completarse; pero en muchos casos puede que no sea posible saber qué futuro será el último en completarse. En tales situaciones, es muy útil poder esperar a que se completen todos los futuros. Antes de continuar. Esto se puede hacer usando concurrent.futures.wait función. Esta función toma una colección de futuros y, opcionalmente, un tiempo de espera y un indicador return_when. esperar (fs, tiempo de espera = ninguno, retorno_cuando = TODO_COMPLETO) dónde: • el tiempo de espera se puede utilizar para controlar el número máximo de segundos de espera antes de volver. timeout puede ser un int o un float. Si no se especifica el tiempo de espera o Ninguno, no hay límite para el tiempo de espera. • return_when indica cuándo debe regresar esta función. debe ser uno de las siguientes constantes: – FIRST_COMPLETED La función regresará cuando cualquier futuro termine o sea cancelado. 400 33 Futuros