Wielowątkowe instrukcje drukowania w Pythonie są opóźnione do momentu zakończenia wszystkich wątków.

Question

Mam poniżej fragment kodu, który tworzy kilka wątków, aby wykonać zadanie, które działa doskonale na własną rękę. Jednak staram się zrozumieć, dlaczego instrukcje drukowania, które wywołuję w mojej funkcji, nie są wykonywane, dopóki wszystkie wątki nie zakończą się i nie zostanie wywołana instrukcja print 'finished'. Oczekuję, że zostaną wywołani podczas wykonywania wątku. Czy istnieje prosty sposób, aby to osiągnąć i dlaczego to działa w ten sposób?

def func(param): 
    time.sleep(.25) 
    print param*2 

if __name__ == '__main__': 
    print 'starting execution' 
    launchTime = time.clock() 
    params = range(10) 
    pool=multiprocessing.Pool(processes=100) #use N processes to download the data 
    _=pool.map(func,params) 
    print 'finished' 

Answer 1

Dzieje się tak ze względu na standardowe buforowanie. Nadal można opróżnić buforów:

import sys 

print 'starting' 
sys.stdout.flush() 

można znaleźć więcej informacji na ten temat here i here.

Answer 2

dla Pythona 3 można teraz używać flush param tak:

print('Your text', flush=True)