溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Python多線程通信queue隊列用法實例分析

發布時間:2020-08-26 19:31:15 來源:腳本之家 閱讀:205 作者:隨風行云 欄目:開發技術

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

queue:

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

【下例為:sender線程發送直徑給recvder線程,recvder計算得出周長】

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

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

def recvder():#recvder計算周長
 while True:
 x=q.get()
 print(threading.current_thread(),"recv done:",x*3.14)#每隔一秒就取出一個元素,計算結果
 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()

注:

隊列可以有容量限制:

Python多線程通信queue隊列用法實例分析

timeout的設置:

Python多線程通信queue隊列用法實例分析


隊列的其他相關函數【設q為一個Queue對象】:

  • q.qsize():返回當前隊列的元素個數
  • q.empty():判斷隊列是否空,返回布爾值
  • q.full():判斷隊列是否滿,返回布爾值
  • q.get_nowait():直接使用get(),如果此時隊列中沒有元素,那么會阻塞等待,使用get_nowait()后,如果隊列中沒有元素,那么會報錯
  • q.put_nowait():直接使用put(),如果此時隊列滿了,那么會阻塞等待,使用put_nowait()后,如果隊列已經滿了,那么會報錯
  • q.task_done() :在完成一項工作之后,task_done()函數向任務已經完成的隊列發送一個信號【功能類似于:有一個只能承重一個人的獨木橋,A來了發現B在橋上,所以A不能上橋,他就在等,等到B過完橋后喊一下他,他才知道B過完橋了】【q.task_done主要是跟q.join()配合使用的】
  • q.join():實際上意味著等到隊列為空,再執行別的操作【每次get后需要調用task_done,直到所有隊列為空,這時才會執行join下面的】
import threading,queue,time
"""
這個例子是:廠家跟司機約定,生產滿3個,司機才來拉,
而一個個拉走,只有當3個都拉走,廠家才繼續生產
"""
def producer():#廠家
 while True:
 for i in range(3):
  q.put(i)
 start_time=time.time()
 q.join()##結果顯示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()

Python多線程通信queue隊列用法實例分析


queue中除了Queue之外,還有其他的隊列,下面是常用的幾個:

  • Queue是先入先出的隊列:

Python多線程通信queue隊列用法實例分析

  • LifoQueue則是后入先出的隊列

Python多線程通信queue隊列用法實例分析

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

Python多線程通信queue隊列用法實例分析Python多線程通信queue隊列用法實例分析

  • deque 是雙端隊列,允許先入先出和后入后出,即兩端都可以出
    • 由于雙端隊列實用性不大,實際上與列表沒什么區別,在此不做闡述,大家可以參考://www.jb51.net/article/183382.htm

更多關于Python相關內容感興趣的讀者可查看本站專題:《Python進程與線程操作技巧總結》、《Python數據結構與算法教程》、《Python函數使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經典教程》、《Python+MySQL數據庫程序設計入門教程》及《Python常見數據庫操作技巧匯總》

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

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女