Problèmes de base avec le multitraitement Python

Question

Je n'arrive pas à comprendre ce qui ne va pas avec le code multitraitement python suivant. Cela ne se termine pas. Toute suggestion serait très appréciée.

from multiprocessing import Process, Queue, Lock 

def hello(num, myqueue): 
    while True: 
     item = myqueue.get() 
     print 'Thread ', num, 'got', item 
    return 

def put_on_queue(myqueue): 
    for i in range(10): 
     myqueue.put(i) 
    return 

if __name__ == '__main__': 
    processes = [] 

    myqueue = Queue() 

    for i in range(4): 
     proc = Process(target = hello, args = (i, myqueue)) 
     proc.start() 
     processes.append(proc) 

    put_on_queue(myqueue) 

    for proc in processes: 
     proc.join() 

-------------- ----------------- EDIT

OK, sur la base des commentaires J'ai reçu, et de l'aide en ligne j'ai révisé mon code comme ci-dessous. Toujours pas de chance :-(

def hello(num, myqueue): 
    while not exit_flag: 
    item = myqueue.get(False,5) 
    print 'Thread ', num, 'got', item 
    return 


def put_on_queue(myqueue): 
    global exit_flag 
    for i in range(10):   
    myqueue.put(i) 

    while not myqueue.empty(): 
     pass 
    exit_flag = 1 

    return 

if __name__ == '__main__': 
    mylock = Lock() 
    processes = [] 
    myqueue = Queue() 

    exit_flag = 0 

    for i in range(4): 
    proc = Process(target = hello, args = (i, myqueue)) 
    #proc.daemon = True 
    proc.start() 
    processes.append(proc) 

    put_on_queue(myqueue) 

    for proc in processes: 
    proc.join() 

Answer 1

Il y a une boucle infinie dans votre fonction hello. Vous devez mettre un sentinent comme une dernière valeur dans la file d'attente, vérifiez et sortir de la boucle.