Comment gérer gracieusement l'erreur 'Pipe fermé' dans la communication de tuyaux multi-processus Python?

Python Multi-Process Pipe Communication: solution élégante à l'erreur "Pipe fermé"

Vous pouvez rencontrer une erreur de maux de tête "Fermed" lors de l'utilisation Pipe dans le module multiprocessing de Python pour la communication d'interproduction. Cet article analysera ce problème en profondeur et fournira une solution plus robuste.

Des problèmes se produisent généralement dans les scénarios de communication des processus parent-enfant. Par exemple, après qu'un processus enfant a effectué une tâche qui prend du temps, il envoie des données au processus parent via un pipeline et attend que le signal du processus parent se termine lui-même. Si le processus parent se termine tôt et que le processus de l'enfant essaie de recevoir des données d'un pipeline fermé, une erreur de "pipeline fermée" est augmentée.

Bien que l'ajout time.sleep() et de fermer explicitement les processus enfants dans les processus parents peuvent résoudre le problème, ce n'est pas une solution idéale car elle s'appuie sur l'attente active et le contrôle du processus parent.

Une solution plus élégante consiste à assister à l'exception EOFError dans le processus de l'enfant . Cette exception est augmentée lorsque le processus de l'enfant essaie de recevoir des données du pipeline lorsque le processus parent se termine tôt. En attrapant cette exception, le processus de l'enfant peut sortir gracieusement, en évitant les plantages du programme.

Ce qui suit montre le code service.py et single.py amélioré:

service.py amélioré.py:

 Importer un système d'exploitation
du processus d'importation multiprocesseur, tuyau

def start_child_process (child_conn):
    # Simuler des tâches longues # run_server_for_long_time ()
    child_conn.send ({"port": 123, "ret": 1, "pid": os.getpid ()})

    essayer:
        signal = child_conn.recv () # attendez le signal de processus parent si signal:
            child_conn.close ()
    sauf eoferror comme e:
        print (f "eoferror: {e}") # maniement élégant des exceptions # Vous pouvez ajouter le serveur de classe de nettoyage nécessaire: serveur de classe:
    def __init __ (soi):
        self.child_conn = aucun
        self.child = aucun
        self.parent_conn, self.child_conn = pipe ()

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

        data = self.parent_conn.recv ()
        résultat = {
            "points de terminaison": {
                "http": f "http://127.0.0.1: {data['port '
                "ws": f "ws: //127.0.0.1: {data ['port']} / api",
            }
        }
        Résultat de retour

    Def Stop (soi):
        self.parent_conn.send (true)
        self.child.join ()
        self.child = aucun

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

Amélioré single.py :

 De Service Import Server

def main ():
    server =
    result = server.run ()
    imprimer ("r:", résultat)
    # server.stop () # Facultatif: Arrêtez explicitement le processus de l'enfant si __name__ == "__main__":
    principal()

Catching EOFError en ajoutant try...except un bloc dans le processus de l'enfant, le processus de l'enfant se termine gracieusement même si le processus parent sort de façon inattendue, en évitant l'erreur "Pipeline fermée". Cette approche améliore la robustesse du programme sans s'appuyer sur les opérations de fermeture explicites du processus parent.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!