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("學")

w.send("步")

w.send("園")

w.send("網")

w.close()

運行結果：

學

步

園

網

關于Python線程下queue隊列模塊的用法問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注創新互聯行業資訊頻道了解更多相關知識。