다중 처리에서 여러 비동기 작업자 프로세스 간에 대기열을 공유하는 방법은 무엇입니까?

여러 프로세스에서 결과 공유

다중 처리에서는 대기열과 같은 리소스를 서로 다른 프로세스 간에 공유하는 것이 어려울 수 있습니다. 이 문서에서는 apply_async 함수를 사용하여 여러 비동기 작업자 프로세스 간에 결과 대기열을 공유하는 방법을 살펴봅니다.

multiprocessing.Process를 사용하여 제공된 샘플 코드는 상속을 통해 프로세스 간에 대기열 개체를 공유하는 제한으로 인해 실패합니다. 이러한 제한을 극복하기 위해 multiprocessing.Manager 클래스가 솔루션을 제공합니다.

multiprocessing.Manager 사용

multiprocessing.Manager는 다음과 같은 개체를 생성하고 관리하는 방법을 제공합니다. 프로세스 전반에 걸쳐 공유됩니다. 다음 코드는 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.Queue() 대신 m.Queue()를 사용하면 Manager 개체에 의해 대기열이 생성되고 관리됩니다. . 이를 통해 작업자 프로세스는 "큐 객체는 상속을 통해 프로세스 간에만 공유되어야 합니다." 오류가 발생하지 않고 큐에 액세스하고 수정할 수 있습니다.

위 내용은 다중 처리에서 여러 비동기 작업자 프로세스 간에 대기열을 공유하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!