다중 처리에서 \'상속을 통해 프로세스 간에만 대기열 개체를 공유해야 합니다\' 오류를 해결하는 방법은 무엇입니까?

멀티프로세싱으로 공유 대기열 관리

Python의 멀티프로세싱 모듈에서 프로세스 간에 공유 대기열을 생성하려면 multiprocessing.apply_async()를 사용할 때 신중하게 고려해야 합니다. 비동기 작업자 프로세스를 시작합니다. "큐 개체는 상속을 통해서만 프로세스 간에 공유되어야 합니다." 대기열을 작업자에게 직접 전달하려고 하면 오류가 발생합니다.

이 문제를 해결하려면 multiprocessing.Manager를 활용하여 대기열을 관리하고 작업자 프로세스에서 액세스할 수 있도록 만드세요. multiprocessing.Manager는 공유 메모리 세그먼트에서 다양한 유형의 데이터를 제어하고 직렬화하는 관리자 개체를 생성하는 방법을 제공합니다.

다음 코드 조각은 multiprocessing.Manager를 사용하여 여러 작업자 프로세스 간에 대기열을 공유하는 방법을 보여줍니다.

<code class="python">import multiprocessing

def worker(name, que):
    que.put("%d is done" % name)

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))</code>

이 예에서 multiprocessing.Manager()는 공유 데이터를 관리하는 관리자 개체(m)를 생성하고 작업자 프로세스에 전달할 수 있는 프록시 개체를 제공합니다. m.Queue()를 호출하여 모든 작업자 프로세스에 액세스할 수 있는 관리자가 관리하는 대기열을 만듭니다. 그런 다음 관리자는 프록시 객체를 직렬화하고 작업자에게 전달하여 공유 대기열과 안전하게 통신할 수 있도록 합니다.

위 내용은 다중 처리에서 \'상속을 통해 프로세스 간에만 대기열 개체를 공유해야 합니다\' 오류를 해결하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!