Python線程之線程安全的隊(duì)列Queue
一、什么是隊(duì)列？
像排隊(duì)一樣，從頭到尾排成一排，還可以有人繼續(xù)往后排隊(duì)，這就是隊(duì)列。
這里學(xué)委想說的是Queue這個(gè)類, 它是queue這個(gè)內(nèi)置模塊內(nèi)的一個(gè)類。
import queue q = queue.Queue(5) #可以傳入?yún)?shù)指定隊(duì)列大小 queue.Queue()# 不傳或者給0或者<0的數(shù)字則創(chuàng)建一個(gè)無限長(zhǎng)度的隊(duì)列
它提供了很多函數(shù)，下面幾個(gè)函數(shù)，我們使用的比較多：
get: 獲取并移除隊(duì)頭元素，就是出隊(duì)put： 往隊(duì)列末尾加入元素，也就是后來者排隊(duì)qsize： 獲取隊(duì)列的長(zhǎng)度empty： 隊(duì)列空了，沒有人在排了full： 隊(duì)列滿了。
看著比較枯燥，學(xué)委畫了下圖展示：
這個(gè)隊(duì)列put了3次，依次放入：持續(xù)學(xué)習(xí)，持續(xù)開發(fā)，我雷學(xué)委。隊(duì)列長(zhǎng)度為3
二、隊(duì)列基操 入隊(duì)/出隊(duì)/查隊(duì)列狀態(tài)
準(zhǔn)備了下面的代碼：
import queue
q = queue.Queue(5)
print("學(xué)委粉絲隊(duì)列：", q)
print("空隊(duì)，學(xué)委粉絲隊(duì)列大?。?, q.qsize())
print("空隊(duì)列？", q.empty())
for i in range(5):
? ? q.put(i)
print("隊(duì)列滿了？", q.full())
print("排滿了，學(xué)委粉絲隊(duì)列大小：", q.qsize())
while not q.empty():
? ? print("粉絲 %s 出隊(duì)點(diǎn)贊！" % q.get())
print("最后，學(xué)委粉絲隊(duì)列大小：", q.qsize())這段代碼創(chuàng)建了一個(gè)長(zhǎng)的為5的隊(duì)列。
然后一個(gè)循環(huán)寫滿隊(duì)列，接著再依此出隊(duì)，粉絲出隊(duì)點(diǎn)贊。
下面是運(yùn)行效果：
是不是很簡(jiǎn)單。
三、Queue是一個(gè)線程安全的類
前面幾篇文章，碰到下面的代碼（反復(fù)讀寫共享變量）結(jié)果總是出乎依賴！
amount = 100 def transfer(money): ? ? global amount ? ? for i in range(100000): ? ? ? ? amount += money
如果我們對(duì)隊(duì)列進(jìn)行反復(fù)讀寫，會(huì)不會(huì)出現(xiàn)問題呢？
不妨，寫個(gè)代碼驗(yàn)收一下：
import queue
import threading
xuewei_fans_q = queue.Queue()
def transfer(money):
? ? for i in range(100000):
? ? ? ? xuewei_fans_q.put(money)
? ? ? ? xuewei_fans_q.get()
# 創(chuàng)建4個(gè)任務(wù)重復(fù)給學(xué)委加關(guān)注/脫粉（還是希望各位編程的明日之星跟著學(xué)習(xí)，共同進(jìn)步?。?
t_group = []
for i in range(10):
? ? t = threading.Thread(target=lambda: transfer(-1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(-1))
? ? t_group.append(t)
? ? t.start()
? ? t = threading.Thread(target=lambda: transfer(1))
? ? t_group.append(t)
? ? t.start()
for t in t_group:
? ? t.join()
print("-" * 16)
print("活躍線程數(shù):", threading.active_count())
print("活躍線程:", threading.current_thread().name)
#反復(fù)對(duì)隊(duì)列進(jìn)行添加數(shù)據(jù)，移除數(shù)據(jù)，隊(duì)列最后清零了
print("學(xué)委粉絲隊(duì)列:", xuewei_fans_q.qsize())不管運(yùn)行多少次，隊(duì)列（希望是黑粉隊(duì)列）都為0元素。
總結(jié)：
本篇學(xué)委分享了一個(gè)線程安全的隊(duì)列Queue，這個(gè)非常重要！但是隊(duì)列Queue這個(gè)類是線程安全的，這個(gè)是經(jīng)過驗(yàn)證的
到此這篇關(guān)于Python線程之線程安全的隊(duì)列的文章就介紹到這了,更多相關(guān)Python線程安全隊(duì)列內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Python實(shí)現(xiàn)將列表拆分為大小為N的塊
這篇文章主要為大家整理了一些常見的Python實(shí)現(xiàn)將列表拆分為大小為N的塊的方法,文中的示例代碼講解詳細(xì),具有一定的參考價(jià)值,有需要的小伙伴可以了解下2023-09-09
為何人工智能(AI)首選Python？讀完這篇文章你就知道了（推薦）
這篇文章主要介紹了為何人工智能(AI)首選Python，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
Python實(shí)現(xiàn)郵件發(fā)送功能的示例詳解
Python對(duì)SMTP支持有smtplib和email兩個(gè)模塊，email負(fù)責(zé)構(gòu)造郵件，smtplib負(fù)責(zé)發(fā)送郵件。本文將以qq郵箱為例，實(shí)現(xiàn)自己給自己發(fā)送郵件的功能，感興趣的可以了解一下2022-11-11
本篇文章主要介紹了Django中url的反向查詢的方法，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-03-03
Python接口自動(dòng)化淺析pymysql數(shù)據(jù)庫操作流程
本文主要介紹pymysql安裝、操作流程、語法基礎(chǔ)及封裝操作數(shù)據(jù)庫類,需要的朋友可以參考下，希望能對(duì)大家有所幫助，每日提升一點(diǎn)點(diǎn)，歡迎大家多多交流討論2021-08-08
Python語法學(xué)習(xí)之線程的創(chuàng)建與常用方法詳解
本文主要介紹了線程的使用，線程是利用進(jìn)程的資源來執(zhí)行業(yè)務(wù)，并且通過創(chuàng)建多個(gè)線程，對(duì)于資源的消耗相對(duì)來說會(huì)比較低，今天就來看一看線程的使用方法具體有哪些吧2022-04-04
這篇文章主要介紹了Python安裝Bs4及使用方法，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04
下面小編就為大家分享一篇python3 發(fā)送任意文件郵件的實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-01-01
Python3獲取電腦IP、主機(jī)名、Mac地址的方法示例
這篇文章主要介紹了Python3獲取電腦IP、主機(jī)名、Mac地址的方法,結(jié)合具體實(shí)例形式分析了Python3基于socket與uuid模塊針對(duì)電腦的IP、主機(jī)名、Mac地址等信息的讀取操作相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下2019-04-04
這篇文章主要介紹了python爬蟲添加請(qǐng)求頭代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12