Python執行緒下queue（佇列）模組的用法（附實例）

這篇文章帶給大家的內容是關於Python線程下queue（隊列）模組的用法，有一定的參考價值，有需要的朋友可以參考一下，希望對你有幫助。

queue模組實現了各種【多生產者-多消費者】隊列。可用於在執行的多個執行緒之間安全的交換資訊。

queue模組定義了3種不同的佇列類別。

3種不同的佇列類別

q=Queue(maxsize):建立一個FIFO(first-in first-out,先進先出)佇列。 maxsize是佇列中金額以放入的項的最大數量。
如果省略maxsize參數或將它置為0，則佇列大小將無限大。

q=LifoQueue(maxsize)：建立一個LIFO（last-in first-out，後進先出）佇列(堆疊)。

q=PriorityQueue(maxsize)：建立一個優先權佇列，其中項目依照優先權從低到高依序排好。
使用這種佇列時，項目應該是(priority,data)形式的元組，其中priority時一個標識優先權的數字。

常用方法

q.size()：傳回佇列的正確大小。因為其他執行緒可能正在更新此佇列，所以此方法的傳回數字不可靠。

q.empty()：如果佇列為空，則傳回True，否則回傳False。

q.full()：如果佇列已滿，則傳回True，否則回傳False。

q.put(item,block,timeout)：將item放入佇列。
如果block設為True（預設值），呼叫者將被阻塞直到佇列中出現可用的空閒位置為止。
如果block設為False，佇列滿時此方法將引發Full異常。

q.put_nowait(item):等價於q.put(item,False)

q.get(block,timeout):從佇列中刪除一項，然後傳回這個項。
如果block設為True（預設值），呼叫者將阻塞，直到佇列中出現可用的空閒為止。
如果block設為False，佇列為空時將引發Empty異常。
timeout提供可選的超時值，單位為秒，如果超時，將引發Empty異常。

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中使用Queue和Condition進行執行緒同步的方法

以上是Python執行緒下queue（佇列）模組的用法（附實例）的詳細內容。更多資訊請關注PHP中文網其他相關文章！