Was bewirkt ein Aufruf von queue.join() im Haupt-Thread auf Nicht-Haupt-Threads?

Question

Mein Code ist wie unten,

import time, queue, threading 

def washer(dishes, dish_queue): 
    for dish in dishes: 
     print ("Washing", dish) 
     time.sleep(1) 
     dish_queue.put(dish) 

def dryer(dish_queue): 
    while True: 
     dish = dish_queue.get() 
     print("Drying", dish) 
     time.sleep(2) 
     dish_queue.task_done() 
     print('dryer') 

dish_queue = queue.Queue() 
for n in range(2): 
    dryer_thread = threading.Thread(target=dryer, args=(dish_queue,)) 
    dryer_thread.start() 

dishes = ['salad', 'bread', 'entree', 'desert'] 
washer(dishes, dish_queue) 
dish_queue.join() 

Von meinem Verständnis in der Warteschlange Modul Dokumentation, dish_queue.join() den Haupt-Thread, bis die Anzahl der unerledigten Aufgaben blockieren (hier ist nicht getrocknetes Geschirr) auf 0 zurück. Aber ich frage mich, was mit dem 2 dryer_thread passiert ist.

Ich habe festgestellt, dass, wenn ich die Funktion dryer auf einem leeren dish_queue im Hauptprogramm ausführen, das Programm blockiert ist (BTW, ist dies der sogenannte Block von Dish_queue.get()?). Also, wenn dish_queue.join() den Haupt-Thread freigibt, die 2 dryer_thread auch entsperren und den Speicher freigeben? Was bedeutet Block bedeuten sowieso in der Warteschlange doc?

Answer 1

Die kurze Antwort auf Ihre Hauptfrage ist nichts.

Für eine längere Antwort, hier sind zwei Gleichzeitigkeit graphischen Darstellungen, eine ohne Wartezeit:

Und eins mit:

Wie Sie am Anfang sehen können sowohl die beiden Trockner Gewinde sind in eine Sperre, die, wie Sie richtig verstanden haben, get() Block ist. Jetzt, im ersten Fall, endet das Hauptgewinde nach Beendigung der Waschfunktion. Beim Hinzufügen der dish_queue.join() wartet der Haupt-Thread auf die Dish-Warteschlange, um alle Aufgaben zu beenden. Wenn Sie also sagen, dass join() den Hauptthread freigibt, heißt das, dass er seinen eigenen Block entfernt. Wie Sie sehen können, sind die anderen Threads davon nicht betroffen und bleiben blockiert.

Was Block ist, ist es, wenn ein Thread oder ein Prozess auf Eingaben von außerhalb des Threads wartet oder in diesem Fall auf das Element in der Warteschlange wartet. Falls Sie die anderen Threads stoppen möchten, müssen Sie entweder eine Zeitüberschreitung zu get() hinzufügen (die eine Ausnahme auslöst und den Thread beendet), oder sie nach der dish_queue.join() beenden.