Python에서 여러 프로세스 간에 결과 대기열을 공유하는 방법은 무엇입니까?

여러 프로세스 간에 결과 대기열을 공유하는 방법

multiprocessing 모듈의 apply_async를 사용하여 비동기 작업자 프로세스로 작업하는 경우 () 함수를 사용하려면 대기열을 안전하게 공유하는 방법을 고려하는 것이 중요합니다. "런타임 오류: 큐 개체는 상속을 통해 프로세스 간에만 공유되어야 합니다." 오류는 피클링/피클링 해제 문제를 방지하는 방식으로 큐를 전달해야 함을 강조합니다.

이 문제를 해결하려면 멀티프로세싱.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>

이 예에서는 Manager 객체(m)를 생성하고 이를 사용하여 다음 작업을 수행합니다. 대기열을 관리합니다(q). 이를 통해 비동기 시나리오에서도 여러 프로세스가 안전하게 대기열에 액세스할 수 있는 공유 메모리 세그먼트를 생성합니다.

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