本文實(shí)例講述了Python多線程通信queue隊(duì)列用法。分享給大家供大家參考，具體如下：

queue:

• 什么是隊(duì)列：是一種特殊的結(jié)構(gòu)，類似于列表。不過(guò)就像排隊(duì)一樣，隊(duì)列中的元素一旦取出，那么就會(huì)從隊(duì)列中刪除。
• 線程之間的通信可以使用隊(duì)列queue來(lái)進(jìn)行
• 線程如何使用queue.Queue【還有其他類型的對(duì)象下面講】來(lái)通信：
  • 1.創(chuàng)建一個(gè)Queue對(duì)象：對(duì)象=queue.Queue(x)，x是隊(duì)列容量，x可以不填，默認(rèn)沒(méi)有容量限制，    
  • 2.get()可以使線程從隊(duì)列中獲取一個(gè)元素，如果隊(duì)列為空，get會(huì)等待，get可以設(shè)置timeout參數(shù)，這是等待時(shí)間
  • 3.put()可以往隊(duì)列中放入一個(gè)元素【默認(rèn)隊(duì)列Queue是先入先出的，先放入的元素會(huì)先取出去】，如果隊(duì)列滿了，put會(huì)等待，put可以設(shè)置timeout參數(shù)，這是等待時(shí)間
  • 

【下例為：sender線程發(fā)送直徑給recvder線程，recvder計(jì)算得出周長(zhǎng)】

import threading,time,queue,random
def sender():#sender發(fā)送直徑
 while True:
 x=random.randint(1,10)
 print("send done:",x)
 q.put(x)#每個(gè)一秒就放入一個(gè)隨機(jī)數(shù)
 time.sleep(1)#每隔一秒就放入一個(gè)a

def recvder():#recvder計(jì)算周長(zhǎng)
 while True:
 x=q.get()
 print("recv done:",x*3.14)#每隔一秒就取出一個(gè)元素，計(jì)算結(jié)果
 time.sleep(1)

q=queue.Queue()
t1=threading.Thread(target=sender)
t2=threading.Thread(target=recvder)

t1.start()
t2.start()

t1.join()
t2.join()

• Queue 對(duì)象已經(jīng)包含了必要的鎖，所以不用擔(dān)心會(huì)出錯(cuò)

import threading,time,queue,random
def sender():#sender發(fā)送直徑
 while True:
 x=random.randint(1,10)
 print("send done:",x)
 q.put(x)#每個(gè)一秒就放入一個(gè)隨機(jī)數(shù)
 time.sleep(1)#每隔一秒就放入一個(gè)a

def recvder():#recvder計(jì)算周長(zhǎng)
 while True:
 x=q.get()
 print(threading.current_thread(),"recv done:",x*3.14)#每隔一秒就取出一個(gè)元素，計(jì)算結(jié)果
 time.sleep(2)


q=queue.Queue()
t1=threading.Thread(target=sender)
t2=threading.Thread(target=recvder)
t3=threading.Thread(target=recvder)

t1.start()
t2.start()
t3.start()

t1.join()
t2.join()
t3.join()

注：

隊(duì)列可以有容量限制：

timeout的設(shè)置:

隊(duì)列的其他相關(guān)函數(shù)【設(shè)q為一個(gè)Queue對(duì)象】：

• q.qsize()：返回當(dāng)前隊(duì)列的元素個(gè)數(shù)
• q.empty():判斷隊(duì)列是否空，返回布爾值
• q.full():判斷隊(duì)列是否滿，返回布爾值

• q.get_nowait():直接使用get(),如果此時(shí)隊(duì)列中沒(méi)有元素，那么會(huì)阻塞等待，使用get_nowait()后，如果隊(duì)列中沒(méi)有元素，那么會(huì)報(bào)錯(cuò)
• q.put_nowait():直接使用put(),如果此時(shí)隊(duì)列滿了，那么會(huì)阻塞等待，使用put_nowait()后，如果隊(duì)列已經(jīng)滿了，那么會(huì)報(bào)錯(cuò)

• q.task_done() :在完成一項(xiàng)工作之后，task_done()函數(shù)向任務(wù)已經(jīng)完成的隊(duì)列發(fā)送一個(gè)信號(hào)【功能類似于：有一個(gè)只能承重一個(gè)人的獨(dú)木橋，A來(lái)了發(fā)現(xiàn)B在橋上，所以A不能上橋，他就在等，等到B過(guò)完橋后喊一下他，他才知道B過(guò)完橋了】【q.task_done主要是跟q.join()配合使用的】
• q.join():實(shí)際上意味著等到隊(duì)列為空，再執(zhí)行別的操作【每次get后需要調(diào)用task_done，直到所有隊(duì)列為空，這時(shí)才會(huì)執(zhí)行join下面的】

import threading,queue,time
"""
這個(gè)例子是：廠家跟司機(jī)約定，生產(chǎn)滿3個(gè)，司機(jī)才來(lái)拉，
而一個(gè)個(gè)拉走，只有當(dāng)3個(gè)都拉走，廠家才繼續(xù)生產(chǎn)
"""
def producer():#廠家
 while True:
 for i in range(3):
  q.put(i)
 start_time=time.time()
 q.join()##結(jié)果顯示join這里堵塞住了廠家線程
 print("wait time:",time.time()-start_time)#用來(lái)測(cè)試是否堵塞，證明不是因?yàn)樗緳C(jī)的sleep堵塞運(yùn)行


def driver():#老司機(jī)
 while True:
 for i in range(3):
  print(q.get())
  q.task_done()
 print("")
 time.sleep(2)


q=queue.Queue()
t1=threading.Thread(target=producer)
t2=threading.Thread(target=driver)

t1.start()
t2.start()

t1.join()
t2.join()

queue中除了Queue之外，還有其他的隊(duì)列,下面是常用的幾個(gè)：

• Queue是先入先出的隊(duì)列：

• LifoQueue則是后入先出的隊(duì)列：

• PriorityQueue是由裝入元素時(shí)指定的優(yōu)先級(jí)來(lái)決定出元素的順序的：
  • 創(chuàng)建方法：隊(duì)列對(duì)象=queue.PriorityQueue()
  • 優(yōu)先級(jí)是小的優(yōu)先，但不能混合排序,str的只能跟str的一起排序，int的只能跟int一起排序
  • PriorityQueue的put的參數(shù)是元組，格式為：隊(duì)列對(duì)象.put((優(yōu)先級(jí), 數(shù)據(jù)))

• deque 是雙端隊(duì)列，允許先入先出和后入后出，即兩端都可以出
  • 由于雙端隊(duì)列實(shí)用性不大，實(shí)際上與列表沒(méi)什么區(qū)別，在此不做闡述，大家可以參考：//www.fzitv.net/article/183382.htm

更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Python進(jìn)程與線程操作技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》、《Python入門(mén)與進(jìn)階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫(kù)程序設(shè)計(jì)入門(mén)教程》及《Python常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》

希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。

最新評(píng)論