파이썬에서 동시 프로그래밍을 위해 스레드-안전 큐를 구현하는 방법은 무엇입니까?

사용 queue.queue는 Python 스레드 안전 큐를 구현하는 가장 신뢰할 수있는 방법입니다. 1. 인종 조건을 피하기위한 내장 잠금 장치가 있습니다. 2. 기본적으로 put () 및 get () 블록을하고 무한 대기를 피하기 위해 시간 초과를 지원합니다. 3. Task_done () 및 join ()을 사용하여 작업 완료를 조정하십시오. 4. 메모리를 제어하기 위해 경계 대기열을 구현하도록 최대 크기를 설정할 수 있습니다. 5. 사용자 정의 캡슐화는 더 명확한 인터페이스를 제공 할 수 있습니다. 6. queue.queue는 스레드 간 통신에만 사용되며 다중 프로세스 시나리오에 적합하지 않습니다. join ()을 사용하는 경우 소비자에서 task_done ()을 호출해야합니다. 그렇지 않으면 프로그램이 중단 될 수 있습니다.

Python에서 스레드 안전 큐를 구현하는 것은 여러 스레드에서 안전하게 사용하도록 특별히 설계된 내장 queue.Queue 클래스 덕분에 간단합니다. 올바르게 수행하는 방법과 명심해야 할 사항은 다음과 같습니다.

스레드 안전을 위해 queue.Queue 사용하십시오

파이썬에 스레드 안전 큐를 갖는 가장 신뢰할 수 있고 간단한 방법은 queue.Queue 사용하는 것입니다. 내부적으로 모든 잠금 장치를 처리하므로 항목을 넣거나 얻을 때 인종 조건에 대해 걱정할 필요가 없습니다.

 가져 오기 큐
스레딩 가져 오기
수입 시간

# 스레드 안전 큐를 만듭니다
q = queue.queue ()

def producer () :
    범위 (5)의 i를 위해 :
        항목 = f "항목-{i}"
        Q.put (항목)
        print (f "생산 : {item}")
        Time.sleep (0.1) # 작업 시뮬레이션

Def Consumer () :
    사실이지만 :
        노력하다:
            # 시간 초과를 사용하여 영원히 차단을 피하십시오
            항목 = Q.get (타임 아웃 = 1)
            print (f "소비 : {item}")
            Q.task_done () # 작업이 완료되었음을 나타냅니다
        queue.empty를 제외하고 :
            인쇄 ( "더 이상 항목 없음, 종료.")
            부서지다

# 스레드를 만듭니다
t1 = 스레딩. 스레드 (target = producer)
t2 = 스레딩. 스레드 (target = 소비자)

# 스레드를 시작합니다
t1.start ()
t2.start ()

# 두 스레드가 끝날 때까지 기다립니다
t1.join ()
t2.join ()

queue.Queue 사용의 핵심 포인트

• 차단 작업 : put() 및 get() 블록은 기본적으로 스레드를 조정하는 데 유용합니다.
• task_done() 및 join() : 각 항목을 처리 한 후 task_done() 사용하면 생산자의 q.join() 에게 전화하여 모든 항목이 처리 될 때까지 기다릴 수 있습니다.
• queue.Empty 및 queue.Full 예외를 피하십시오 . 블로킹이 아닌 타임 아웃 또는 타임 아웃 기반 통화를 사용할 때는 항상 처리하십시오.

q.join() 의 예제 :

 def producer_with_join () :
    범위 (3)의 i를 위해 :
        Q. put (f "task- {i}")
    Q.join () # 모든 작업이 완료 될 때까지 기다리십시오.
    인쇄 ( "모든 작업이 완료되었습니다.")

def consumer_with_task_done () :
    사실이지만 :
        항목 = Q.get ()
        항목이 없으면 :
            부서지다
        print (f "Processing {item}")
        Time.sleep (0.5)
        Q.task_done () # 마크 작업이 완료되었습니다

대안 : 제한된 대기열 (크기 제한)

메모리 사용을 제어하고 배압을 활성화하기 위해 큐 크기를 제한 할 수 있습니다.

 q = queue.queue (maxsize = 3)

이제 항목이 소비 될 때까지 큐가 가득 차면 put() 가 차단됩니다.

사용자 정의 스레드 안전 큐 (고급 유스 케이스)

queue.Queue 는 대부분의 요구를 다루지 만 특정 행동을 위해 마무리 할 수 있습니다.

 가져 오기 큐
가져 오기 입력에서

Class Safequeue :
    def __init __ (self, maxsize : int = 0) :
        self._q = queue.queue (maxsize = maxsize)

    DEF PUT (Self, Item : Any) :
        self._q.put (항목)

    def get (self) -> any :
        return self._q.get ()

    def empty (self) -> bool :
        self._q.empty () 반환

    def size (self) -> int :
        return self._q.qsize ()

    def task_done (self) :
        self._q.task_done ()

    DEF 조인 (self) :
        self._q.join ()

이것은 큐를 캡슐화하고 깨끗한 인터페이스를 제공합니다.

중요한 메모

• 매우 구체적인 이유가없는 한 수동으로 잠금 장치로 list 사용하지 마십시오 . 오류가 발생하기 쉽습니다.
• queue.Queue 스레드 전용입니다. 멀티 프로세싱의 경우 multiprocessing.Queue 사용하십시오.
• join() 사용하거나 프로그램이 중단 될 경우 항상 소비자의 task_done() 호출하십시오.

기본적으로, queue.Queue 사용하십시오-잘 테스트하고 효율적 이며이 정확한 목적을 위해 구축됩니다.

위 내용은 파이썬에서 동시 프로그래밍을 위해 스레드-안전 큐를 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!