Wie teile ich eine Ergebniswarteschlange zwischen mehreren Prozessen mithilfe von multiprocessing.Manager?

Gemeinsame Nutzung einer Ergebniswarteschlange zwischen mehreren Prozessen mithilfe von multiprocessing.Manager

Beim Multiprocessing ist die gemeinsame Nutzung einer Warteschlange zwischen übergeordneten und untergeordneten Prozessen für die Kommunikation und den Ergebnisabruf von entscheidender Bedeutung. Die Verwendung von apply_async zum Starten asynchroner Arbeitsprozesse stellt jedoch Herausforderungen bei der gemeinsamen Nutzung von Warteschlangen dar.

Um den Fehler „Warteschlangenobjekte sollten nur durch Vererbung zwischen Prozessen geteilt werden“ zu beheben, können wir multiprocessing.Manager verwenden. Diese Managerklasse ermöglicht die Erstellung und Verwaltung gemeinsam genutzter Ressourcen, einschließlich Warteschlangen.

Indem wir unsere Warteschlangenerstellung in den multiprocessing.Manager()-Kontext einschließen, können wir sie allen Arbeitern zugänglich machen. So ändern Sie den Code:

<code class="python">if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))</code>

Jetzt kann jeder Arbeiter mit dem gemeinsam genutzten q-Objekt interagieren und Ergebnisse an den Basisprozess zurückmelden. Dieser Ansatz ermöglicht eine effiziente und zuverlässige Ergebniskommunikation unter Beibehaltung der asynchronen Natur von apply_async.

Das obige ist der detaillierte Inhalt vonWie teile ich eine Ergebniswarteschlange zwischen mehreren Prozessen mithilfe von multiprocessing.Manager?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!