Wie rufe ich Rückgabewerte von Multiprocessing.Process-Funktionen in Python ab?

Zugriff auf den Rückgabewert einer Funktion in Multiprocessing.Process

Beim Multiprocessing mit Python das Abrufen des Rückgabewerts einer an Multiprocessing übergebenen Funktion. Der Prozess kann schwierig sein, da er nicht direkt im Prozessobjekt gespeichert wird.

Bedenken Sie Folgendes Beispiel:

import multiprocessing

def worker(procnum):
    '''worker function'''
    print(str(procnum) + ' represent!')
    return procnum


if __name__ == '__main__':
    jobs = []
    for i in range(5):
        p = multiprocessing.Process(target=worker, args=(i,))
        jobs.append(p)
        p.start()

    for proc in jobs:
        proc.join()
    print(jobs)

Während dieser Code die Ausgabe jedes Arbeitsprozesses ausgibt, können wir nicht direkt auf deren Rückgabewerte zugreifen.

Um die Rückgabewerte abzurufen, können wir eine gemeinsam genutzte Variable verwenden. Im folgenden überarbeiteten Code wird ein Manager() aus dem Multiprocessing-Modul verwendet, um ein gemeinsames Wörterbuch zu erstellen:

import multiprocessing


def worker(procnum, return_dict):
    """worker function"""
    print(str(procnum) + " represent!")
    return_dict[procnum] = procnum


if __name__ == "__main__":
    manager = multiprocessing.Manager()
    return_dict = manager.dict()
    jobs = []
    for i in range(5):
        p = multiprocessing.Process(target=worker, args=(i, return_dict))
        jobs.append(p)
        p.start()

    for proc in jobs:
        proc.join()
    print(return_dict.values())

Hier aktualisiert jeder Arbeitsprozess das gemeinsame Wörterbuch return_dict mit seinem Rückgabewert. Der Hauptprozess kann dann auf diese Werte aus dem freigegebenen Wörterbuch zugreifen.

Das obige ist der detaillierte Inhalt vonWie rufe ich Rückgabewerte von Multiprocessing.Process-Funktionen in Python ab?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!