Wie kann man mit dem Fehler in der Python-Multi-Process-Rohrkommunikation anmutig umgehen?

Python Multi-Process-Rohrkommunikation: Elegante Lösung für "Pipe Closed" -Fehler

Sie können einen Kopfschmerz "Pipe Closed" -Fehler begegnen, wenn Sie Pipe -Methode im multiprocessing von Python für die Interprozesskommunikation verwenden. Dieser Artikel wird dieses Problem eingehend analysieren und eine robustere Lösung bieten.

Probleme treten normalerweise in Kommunikationsszenarien für Kinder-Kind-Prozess auf. Nachdem ein untergeordneter Prozess eine zeitaufwändige Aufgabe ausgeführt hat, sendet er Daten über eine Pipeline an den übergeordneten Prozess und wartet darauf, dass das Signal des übergeordneten Prozesses selbst endet. Wenn der übergeordnete Prozess frühzeitig endet und der untergeordnete Prozess versucht, Daten von einer geschlossenen Pipeline zu empfangen, wird ein Fehler "Pipeline geschlossen" erhöht.

Während das Hinzufügen von time.sleep() und das expliziten Schließen von untergeordneten Prozessen in übergeordneten Prozessen das Problem lösen können, ist dies keine ideale Lösung, da es sich auf aktives Warten und die Kontrolle des übergeordneten Prozesss stützt.

Eine elegantere Lösung besteht darin, die Ausnahme EOFError im Kinderprozess zu fangen. Diese Ausnahme wird angesprochen, wenn der untergeordnete Prozess versucht, Daten aus der Pipeline zu empfangen, wenn der übergeordnete Prozess frühzeitig endet. Durch das Fangen dieser Ausnahme kann der Kinderprozess anmutig beenden und Programmabstürze vermeiden.

Das Folgende zeigt den verbesserten service.py und single.py Code:

Verbesserter service.py :

 OS importieren
aus dem Multiprozessing -Importprozess, Rohr

Def start_child_process (child_conn):
    # Simulieren zeitaufwändige Aufgaben# Run_Server_for_long_time ()
    Child_conn.send ({"Port": 123, "ret": 1, "pid": os.getPid ()})

    versuchen:
        Signal = child_conn.recv () # Warten Sie auf das übergeordnete Prozesssignal, wenn Signal:
            Child_conn.close ()
    außer eoFerror als e:
        print (f "eoFerror: {e}") # Elegantes Handling von Ausnahmen # Sie können die erforderliche Aufräumarbeiten hier Class Server hinzufügen:
    def __init __ (selbst):
        self.child_conn = keine
        self.child = keine
        self.parent_conn, self.child_conn = pipe ())

    def run (self):
        self.child = prozess (target = start_child_process, name = "my_child_process", args = (self.child_conn,))
        self.child.start ()

        Data = self.parent_conn.recv ()
        result = {
            "Endpunkte": {{
                "http": f "http://127.0.0.1: {data?port'] weibs }/cmd",
                "WS": F "WS: //127.0.0.1: {data ['port']}/api",
            }
        }
        Rückgabeergebnis

    def stopp (selbst):
        self.parent_conn.send (true)
        self.child.join ()
        self.child = keine

Wenn __name__ == "__main__":
    server = server ()
    r = server.run ()
    print ("r:", r)

Verbesserte single.py :

 Vom Service Import -Server

Def Main ():
    server = server ()
    result = server.run ()
    print ("R:", Ergebnis)
    # server.stop () # Optional: Optional: Oben Sie den untergeordneten Prozess explizit an, wenn __name__ == "__main__":
    hauptsächlich()

Fangen Sie EOFError durch Hinzufügen try...except im untergeordneten Prozess endet der Kinderprozess anmutig, auch wenn der übergeordnete Prozess unerwartet ausgeht und den Fehler "Pipeline geschlossen" vermeidet. Dieser Ansatz verbessert die Robustheit des Programms, ohne sich auf explizite Abschaltvorgänge des übergeordneten Prozesses zu stützen.

Das obige ist der detaillierte Inhalt vonWie kann man mit dem Fehler in der Python-Multi-Process-Rohrkommunikation anmutig umgehen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!