Python線程下queue隊列模塊的用法，針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設,凌海企業(yè)網(wǎng)站建設,凌海品牌網(wǎng)站建設,網(wǎng)站定制,凌海網(wǎng)站建設報價,網(wǎng)絡營銷,網(wǎng)絡優(yōu)化,凌海網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

queue模塊實現(xiàn)了各種【多生產(chǎn)者-多消費者】隊列?？捎糜谠趫?zhí)行的多個線程之間安全的交換信息。

queue模塊定義了3種不同的隊列類。

3種不同的隊列類

q=Queue(maxsize):創(chuàng)建一個FIFO(first-in first-out,先進先出)隊列。maxsize是隊列中金額以放入的項的較大數(shù)量。

如果省略maxsize參數(shù)或將它置為0，隊列大小將無窮大。

q=LifoQueue(maxsize)：創(chuàng)建一個LIFO(last-in first-out，后進先出)隊列(棧)。

q=PriorityQueue(maxsize)：創(chuàng)建一個優(yōu)先級隊列，其中項按照優(yōu)先級從低到高依次排好。

使用這種隊列時，項應該是(priority,data)形式的元組，其中priority時一個標識優(yōu)先級的數(shù)字。

常用方法

q.size()：返回隊列的正確大小。因為其他線程可能正在更新此隊列，所以此方法的返回數(shù)字不可靠。

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

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

q.put(item,block,timeout)：將item放入隊列。

如果block設為True(默認值)，調用者將被阻塞直到隊列中出現(xiàn)可用的空閑位置為止。

如果block設為False，隊列滿時此方法將引發(fā)Full異常。

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

q.get(block,timeout):從隊列中刪除一項，然后返回這個項。

如果block設為True(默認值)，調用者將阻塞，直到隊列中出現(xiàn)可用的空閑為止。

如果block設為False，隊列為空時將引發(fā)Empty異常。

timeout提供可選的超時值，單位為秒，如果超時，將引發(fā)Empty異常。

q.get_nowait()：等價于get(0)

q.task_done():在隊列種數(shù)據(jù)的消費者用來指示對于項的處理已經(jīng)結束。如果使用此方法，那么從隊列中刪除的每一項都應該調用一次。

q.join()：阻塞直到隊列中的所有項均被刪除和處理為止。一旦為隊列中的每一項都調用了一次q.task_done()方法，此方法將會直接返回。

實例：

使用 隊列一般可以簡化多線程的程序。例如，可以使用共享隊列將線程連接在一起，而不必依賴鎖的保護。

在這種模型下，工作者線程一般充當數(shù)據(jù)的消費者。

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

#實際開發(fā)中，此處應該使用有用的工作代替

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ǎng)")

w.close()

運行結果：

學

步

園

網(wǎng)

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

當前標題：Python線程下queue隊列模塊的用法-創(chuàng)新互聯(lián)
轉載來于：http://chinadenli.net/article28/cepsjp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供電子商務、自適應網(wǎng)站、品牌網(wǎng)站制作、軟件開發(fā)、網(wǎng)站設計公司、全網(wǎng)營銷推廣

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)