Duda con hilos y futures en Python

[AlvaroG]

Primero: no importes módulos que no necesitas, solamente complican la lectura del código (threading en tu primer listado, Executor en el segundo). Además, estás importando los símbolos de FileThreadCall.py pero no la clase en sí. Cuidado con eso.

Segundo: Python no tiene un método "main", pero tiene una solución idiomática para la misma funcionalidad.

Tercero: utiliza los iteradores correctamente. No es necesario que uses las formas de comprensión de listas, pero al menos no utilices índices cuando no es necesario.

Tu segundo listado es equivalente al siguiente bloque:

Código Python:

from archivo_donde_esta_FileThreadCall import FileThreadCall
from concurrent.futures.thread import ThreadPoolExecutor
 
if __name__ == '__main__':
    try:
        fichs = [ open('pr'), open('pr2'), open('pr3') ]
        exe=ThreadPoolExecutor(3)
        future = [ exe.submit(FileThreadCall(file)) for file in fichs ]
 
        for f in future:
            print(f.result())
 
    finally:
        for file in fichs:
            file.close()
 

Hechas estas aclaraciones, y luego de ver la documentación del módulo, creo que el problema está en la forma en la que estás mostrando los resultados. Estás llamando al método result() de cada future secuencialmente, cuando lo que hace este método es esperar hasta que el future termina y luego devolver el resultado.

Es decir, en tu bucle for esperas hasta que futures[0] termine, luego a que 1 termine, y luego a que 2 termine. Es ese bloque el que determina que obtengas los resultados secuencialmente.

Para obtener los resultados a medida que se van obteniendo, usa la función as_completed del módulo futures, tal y como está en el ejemplo aquí: http://docs.python.org/dev/library/c...ecutor-example

Cambia tu bucle (línea 10 en el código anterior) por:

Código Python:

for f in concurrent.futures.as_completed(future):
    print(f.result())
 

Saludos.