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

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

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

import threading,time,queue,randomdef sender():#sender發(fā)送直徑 while True: x=random.randint(1,10) print('send done:',x) q.put(x)#每個一秒就放入一個隨機數(shù) time.sleep(1)#每隔一秒就放入一個adef recvder():#recvder計算周長 while True: x=q.get() print('recv done:',x*3.14)#每隔一秒就取出一個元素，計算結(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 對象已經(jīng)包含了必要的鎖，所以不用擔(dān)心會出錯

import threading,time,queue,randomdef sender():#sender發(fā)送直徑 while True: x=random.randint(1,10) print('send done:',x) q.put(x)#每個一秒就放入一個隨機數(shù) time.sleep(1)#每隔一秒就放入一個adef recvder():#recvder計算周長 while True: x=q.get() print(threading.current_thread(),'recv done:',x*3.14)#每隔一秒就取出一個元素，計算結(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()

注：

隊列可以有容量限制：

timeout的設(shè)置:

隊列的其他相關(guān)函數(shù)【設(shè)q為一個Queue對象】： q.qsize()：返回當(dāng)前隊列的元素個數(shù) q.empty():判斷隊列是否空，返回布爾值 q.full():判斷隊列是否滿，返回布爾值 q.get_nowait():直接使用get(),如果此時隊列中沒有元素，那么會阻塞等待，使用get_nowait()后，如果隊列中沒有元素，那么會報錯 q.put_nowait():直接使用put(),如果此時隊列滿了，那么會阻塞等待，使用put_nowait()后，如果隊列已經(jīng)滿了，那么會報錯 q.task_done() :在完成一項工作之后，task_done()函數(shù)向任務(wù)已經(jīng)完成的隊列發(fā)送一個信號【功能類似于：有一個只能承重一個人的獨木橋，A來了發(fā)現(xiàn)B在橋上，所以A不能上橋，他就在等，等到B過完橋后喊一下他，他才知道B過完橋了】【q.task_done主要是跟q.join()配合使用的】 q.join():實際上意味著等到隊列為空，再執(zhí)行別的操作【每次get后需要調(diào)用task_done，直到所有隊列為空，這時才會執(zhí)行join下面的】

import threading,queue,time'''這個例子是：廠家跟司機約定，生產(chǎn)滿3個，司機才來拉，而一個個拉走，只有當(dāng)3個都拉走，廠家才繼續(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)#用來測試是否堵塞，證明不是因為司機的sleep堵塞運行def driver():#老司機 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之外，還有其他的隊列,下面是常用的幾個： Queue是先入先出的隊列：

LifoQueue則是后入先出的隊列：

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

deque 是雙端隊列，允許先入先出和后入后出，即兩端都可以出 由于雙端隊列實用性不大，實際上與列表沒什么區(qū)別，在此不做闡述，大家可以參考：//www.jb51.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入門與進(jìn)階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫程序設(shè)計入門教程》及《Python常見數(shù)據(jù)庫操作技巧匯總》

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