Python 스레드에서 큐(queue) 모듈 사용(예제 포함)

이 기사의 내용은 Python 스레드에서 큐(queue) 모듈의 사용에 대한 것입니다. 특정 참고 값이 있으므로 도움이 될 수 있습니다.

queue 모듈은 다양한 [다중 생산자-다중 소비자] 대기열을 구현합니다. 여러 실행 스레드 간에 정보를 안전하게 교환하는 데 사용할 수 있습니다.

queue 모듈은 3개의 서로 다른 대기열 클래스를 정의합니다.

3가지 다른 대기열 클래스

q=Queue(maxsize): FIFO(선입선출, 선입선출) 대기열을 생성합니다. maxsize는 대기열에 넣을 수 있는 최대 항목 수입니다.
maxsize 매개변수를 생략하거나 0으로 설정하면 대기열 크기가 무한해집니다.

q=LifoQueue(maxsize): LIFO(후입선출, 후입선출) 대기열(스택)을 생성합니다.

q=PriorityQueue(maxsize): 항목이 낮은 우선순위에서 높은 우선순위로 정렬되는 우선순위 대기열을 생성합니다.
이런 종류의 큐를 사용할 때 항목은 (우선순위, 데이터) 형식의 튜플이어야 하며, 여기서 우선순위는 우선순위를 식별하는 숫자입니다.

Common 메서드

q.size(): 대기열의 올바른 크기를 반환합니다. 다른 스레드가 이 큐를 업데이트하고 있을 수 있으므로 이 메서드에서 반환된 숫자는 신뢰할 수 없습니다.

q.empty(): 대기열이 비어 있으면 True를 반환하고, 그렇지 않으면 False를 반환합니다.

q.full(): 대기열이 가득 차면 True를 반환하고, 그렇지 않으면 False를 반환합니다.

q.put(item,block,timeout): 항목을 대기열에 넣습니다.
차단이 True(기본값)로 설정된 경우 대기열에 사용 가능한 무료 위치가 나타날 때까지 발신자가 차단됩니다.
블록이 False로 설정된 경우 이 메서드는 대기열이 가득 찼을 때 전체 예외를 발생시킵니다.

q.put_nowait(item): q.put(item,False)

q.get(block, timeout)과 동일: 대기열에서 항목을 삭제한 다음 이 물건을 반품하세요.
차단이 True(기본값)로 설정되면 발신자는 사용 가능한 유휴 시간이 대기열에 나타날 때까지 차단됩니다.
블록이 False로 설정된 경우 대기열이 비어 있으면 빈 예외가 발생합니다.
timeout은 선택적인 시간 초과 값(초)을 제공합니다. 시간이 초과되면 빈 예외가 발생합니다.

q.get_nowait(): get(0)과 동일

q.task_done(): 대기열의 데이터 소비자는 항목이 완료되었습니다. 마침. 이 메서드를 사용하는 경우 대기열에서 제거된 각 항목에 대해 한 번씩 호출해야 합니다.

q.join(): 대기열의 모든 항목이 제거되고 처리될 때까지 차단합니다. 이 메소드는 대기열의 각 항목에 대해 q.task_done() 메소드가 한 번 호출되면 직접 반환됩니다.

예:

큐를 사용하면 일반적으로 멀티스레드 프로그램을 단순화할 수 있습니다. 예를 들어 보호를 위해 잠금에 의존하지 않고도 공유 큐를 사용하여 스레드를 서로 연결할 수 있습니다.

이 모델에서 작업자 스레드는 일반적으로 데이터 소비자 역할을 합니다.

from threading import Thread
from queue import Queue
class WorkerThread(Thread):
    def __init__(self,*args,**kwargs):
        Thread.__init__(self,*args,**kwargs)
        self.input_queue=Queue()

    def send(self,item):
        self.input_queue.put(item)
    def close(self):
        self.input_queue.put(None)
        self.input_queue.join()
    def run(self):
        while True:
            item=self.input_queue.get()
            if item is None:
                break
            #实际开发中，此处应该使用有用的工作代替
            print(item)
            self.input_queue.task_done()
        #完成，指示收到和返回哨兵
        self.input_queue.task_done()
        return

if __name__=="__main__":
    w=WorkerThread()
    w.start()
    w.send("php")
    w.send("中")
    w.send("文")
    w.send("网")
    w.close()

실행 결과:

php
中
文
网

관련 권장 사항:

Python 스레드 우선 순위 큐(queue) 원칙에 대한 종합 분석#🎜🎜 #

Python에서 스레드 동기화를 위해 대기열 및 조건을 사용하는 방법

위 내용은 Python 스레드에서 큐(queue) 모듈 사용(예제 포함)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!