Python Multi-Process Pipe 통신에서 '파이프 폐쇄'오류를 우아하게 처리하는 방법은 무엇입니까?

파이썬 다중 프로세스 파이프 통신 : "파이프 폐쇄"오류에 대한 우아한 솔루션

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 = 없음
        self.child = 없음
        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] }/cmd",
                "ws": f "ws : //127.0.0.1 : {data [ 'port']}/api",
            }
        }
        반환 결과

    def stop (self) :
        self.parent_conn.send (true)
        self.child.join ()
        self.child = 없음

__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 Multi-Process Pipe 통신에서 '파이프 폐쇄'오류를 우아하게 처리하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!