Pythonマルチプロセスパイプ通信で「パイプ閉じた」エラーを優雅に処理する方法は？

Pythonマルチプロセスパイプ通信：「パイプ閉じた」エラーのエレガントなソリューション

プロセス通信のためにPythonのmultiprocessingモジュールでPipeメソッドを使用すると、頭痛の「パイプ閉鎖」エラーに遭遇する場合があります。この記事では、この問題を詳細に分析し、より堅牢なソリューションを提供します。

問題は通常、親子のプロセス通信シナリオで発生します。たとえば、子どものプロセスが時間のかかるタスクを実行した後、パイプラインを介して親プロセスにデータを送信し、親プロセスの信号がそれ自体を終了するのを待ちます。親プロセスが早期に終了し、子プロセスが閉じたパイプラインからデータを受信しようとすると、「パイプラインクローズド」エラーが発生します。

time.sleep()を追加し、親プロセスで子のプロセスを明示的に閉じることは問題を解決できますが、これは親プロセスの積極的な待機と制御に依存するため、理想的な解決策ではありません。

よりエレガントなソリューションは、子プロセスでEOFError例外をキャッチすることです。この例外は、親プロセスが早期に終了したときに、子プロセスがパイプラインからデータを受信しようとするときに提起されます。この例外をキャッチすることにより、子どものプロセスは優雅に終了し、プログラムのクラッシュを回避できます。

以下は、改善されたservice.pyおよびsingle.pyコードを示しています。

service.pyの改善：

 OSをインポートします
マルチプロセッシングインポートプロセスから、パイプ

def start_child_process（child_conn）：
    ＃時間のかかるタスクをシミュレートします＃run_server_for_long_time（）
    child_conn.send（{"port"：123、 "ret"：1、 "pid"：os.getpid（）}）

    試す：
        signal = child_conn.recv（）＃信号の場合、親プロセス信号を待ちます：
            child_conn.close（）
    eoferrorを除くE：
        print（f "eoferror：{e}"）＃例外のエレガントな取り扱い＃ここに必要なクリーンアップ作業を追加することができます。
    def __init __（self）：
        self.child_conn = none
        self.child = none
        self.parent_conn、self.child_conn = pipe（）

    def run（self）：
        self.child = process（target = start_child_process、name = "my_child_process"、args =（self.child_conn、））
        self.child.start（）

        data = self.parent_conn.recv（）
        結果= {
            「エンドポイント」：{
                「http」：f "http://127.0.0.1: {data ['port']、"、
                "ws"：f "ws：//127.0.0.1：{data ['port']}/api"、
            }
        }
        返品結果

    def stop（self）：
        self.parent_conn.send（true）
        self.child.join（）
        self.child = none

__name__ == "__main__"の場合：
    server = server（）
    r = server.run（）
    print（ "r："、r）

改善single.py ：

サービスインポートサーバーから

def main（）：
    server = server（）
    result = server.run（）
    print（ "r："、result）
    ＃server.stop（）＃オプション：__name__ == "__main__"の場合、子プロセスを明示的に停止します。
    主要（）

try...exceptを追加することでEOFErrorをキャッチします...子プロセスのブロックを除いて、子プロセスが予期せず終了しても子どものプロセスが優雅に終了し、「パイプラインクローズド」エラーを避けます。このアプローチは、親プロセスの明示的なシャットダウン操作に依存することなく、プログラムの堅牢性を改善します。

以上がPythonマルチプロセスパイプ通信で「パイプ閉じた」エラーを優雅に処理する方法は？の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。