Python 3.x에서 프로세스 간 통신을 위해 다중 처리 모듈을 사용하는 방법

Python 3.x에서 프로세스 간 통신을 위해 멀티프로세싱 모듈을 사용하는 방법

컴퓨터 기술이 발전하면서 프로그래밍에서는 여러 작업을 동시에 수행해야 하는 경우가 많습니다. 멀티 코어 프로세서를 더 잘 활용하기 위해 Python의 멀티프로세싱 모듈은 동시 프로그램 생성을 위한 간단하면서도 강력한 도구 세트를 제공합니다. 멀티프로세싱 모듈을 사용하면 Python에서 여러 프로세스를 사용하여 동시에 실행하고 필요할 때 통신할 수 있습니다. 이 기사에서는 프로세스 간 통신을 위해 다중 처리 모듈을 사용하는 방법을 소개하고 해당 코드 예제를 제공합니다.

1. 프로세스 간 통신을 위해 Queue 사용
   다중 처리 모듈은 프로세스 간에 데이터를 전달하기 위한 Queue 클래스를 제공합니다. 다음은 프로세스 간 통신을 위해 Queue를 사용하는 예입니다.

from multiprocessing import Process, Queue

def worker(q):
    # 从队列中获取数据并处理
    while True:
        data = q.get()
        if data is None:
            break
        # 处理数据
        print("Worker got:", data)

if __name__ == '__main__':
    # 创建一个队列
    q = Queue()

    # 创建多个进程
    processes = []
    for i in range(3):
        p = Process(target=worker, args=(q,))
        processes.append(p)
        p.start()

    # 往队列中放入数据
    for i in range(10):
        q.put(i)

    # 添加结束标记到队列中
    for i in range(3):
        q.put(None)

    # 等待进程结束
    for p in processes:
        p.join()

위 코드에서는 Queue를 통해 큐에서 데이터를 가져와 처리하는 작업자 함수를 만들었습니다. 그런 다음 세 개의 프로세스를 만들었습니다. 각 프로세스는 작업자 기능을 실행합니다. 기본 프로세스에서는 일부 데이터를 대기열에 넣고 종료 마커를 추가합니다. 마지막으로 모든 프로세스가 끝날 때까지 기다립니다.

2. 프로세스 간 통신을 위해 Pipe 사용
   Queue를 사용하는 것 외에도 다중 처리 모듈은 프로세스 간 양방향 파이프를 생성하기 위한 Pipe 클래스도 제공합니다. 다음은 프로세스 간 통신을 위해 Pipe를 사용하는 예입니다.

from multiprocessing import Process, Pipe

def worker(conn):
    # 接收数据并打印
    data = conn.recv()
    print("Worker got:", data)

    # 发送数据回主进程
    conn.send("Hello from worker")

    # 关闭连接
    conn.close()

if __name__ == '__main__':
    # 创建一个管道
    parent_conn, child_conn = Pipe()

    # 创建子进程
    p = Process(target=worker, args=(child_conn,))
    p.start()

    # 发送数据到子进程
    parent_conn.send("Hello from main process")

    # 接收子进程的返回数据
    data = parent_conn.recv()
    print("Main process got:", data)

    # 等待子进程结束
    p.join()

위 코드에서는 Pipe를 통해 메인 프로세스에서 보낸 데이터를 받아 인쇄하는 작업자 함수를 생성합니다. 그런 다음 메시지를 다시 기본 프로세스로 보냅니다. 기본 프로세스에서는 파이프를 생성하고 포트 중 하나를 하위 프로세스에 전달합니다. 그런 다음 자식 프로세스에 메시지를 보내고 자식 프로세스로부터 반환 데이터를 받습니다. 마지막으로 하위 프로세스가 완료될 때까지 기다립니다.

요약:
프로세스 간 통신을 위해 다중 처리 모듈을 사용하는 것은 매우 간단합니다. 프로세스 간 데이터 전송을 구현하기 위해 큐와 파이프라는 두 가지 클래스를 제공합니다. Queue 클래스는 단방향 통신에 사용되며 put 및 get 메소드를 통해 프로세스 간에 데이터를 전달합니다. Pipe 클래스는 send 및 recv 메서드를 통한 프로세스 간 양방향 통신에 사용됩니다. 큐를 사용하든 파이프를 사용하든 서로 다른 프로세스 간에 데이터를 쉽게 전송할 수 있으므로 작업의 동시 실행 및 프로세스 간 통신이 가능합니다.

위 내용은 Python 3.x에서 프로세스 간 통신을 위해 다중 처리 모듈을 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!