一、Queue理解
從一個(gè)線程向另一個(gè)線程發(fā)送數(shù)據(jù)最安全的方式可能就是使用queue庫(kù)中的隊(duì)列了。創(chuàng)建一個(gè)被多個(gè)線程共享的Queue對(duì)象，這些線程通過(guò)使用put()和get()操作來(lái)向隊(duì)列中添加或者刪除元素。Queue對(duì)象已經(jīng)包含了必要的鎖，所以你可以通過(guò)它在多個(gè)線程間多安全地共享數(shù)據(jù)。

二、原理圖

三、生產(chǎn)者和消費(fèi)者
生產(chǎn)者：生產(chǎn)數(shù)據(jù)放到隊(duì)列中
消費(fèi)者：從隊(duì)列中獲取數(shù)據(jù)
生產(chǎn)者和消費(fèi)者都可以有多個(gè)
四、代碼

#創(chuàng)建一個(gè)隊(duì)列，1代表maxSize q=queue.Queue(1) #創(chuàng)建一個(gè)先進(jìn)先出的隊(duì)列 #q=queue.LifoQueue #創(chuàng)建一個(gè)后進(jìn)先出的隊(duì)列 #q=queue.PriorityQueue #優(yōu)先級(jí)的隊(duì)列#定義生產(chǎn)者線程 class Producer(threading.Thread):def run(self):global qcount=0while True:time.sleep(5)print("生產(chǎn)線程開(kāi)始生產(chǎn)數(shù)據(jù)")count+=1msg="產(chǎn)品{}".format(count)q.put(msg) #默認(rèn)阻塞print(msg) #定義消費(fèi)者線程 class Consumer(threading.Thread):def run(self):global qwhile True:print('消費(fèi)者線程開(kāi)始消費(fèi)線程了')msg=q.get() #默認(rèn)阻塞print('消費(fèi)線程得到了數(shù)據(jù)：{}'.format(msg))time.sleep(2)if __name__ == '__main__':t1=Producer()t2=Consumer()t1.start()t2.start()

q=queue.Queue(1000) 創(chuàng)建一個(gè)先進(jìn)先出的隊(duì)列，1000代表maxSize，隊(duì)列中最多允許1000條數(shù)據(jù)
q=queue.LifoQueue 創(chuàng)建一個(gè)后進(jìn)先出的隊(duì)列
q=queue.PriorityQueue 優(yōu)先級(jí)的隊(duì)列
q.qsize()：隊(duì)列中的數(shù)據(jù)
q.put(msg) #默認(rèn)阻塞
msg=q.get() #默認(rèn)阻塞

在線程世界里，生產(chǎn)者就是生產(chǎn)數(shù)據(jù)的線程，消費(fèi)者就是消費(fèi)數(shù)據(jù)的線程。在多線程開(kāi)發(fā)當(dāng)中，如果生產(chǎn)者處理速度很快，而消費(fèi)者處理速度很慢，那么生產(chǎn)者就必須等待消費(fèi)者處理完，才能繼續(xù)生產(chǎn)數(shù)據(jù)。同樣的道理，如果消費(fèi)者的處理能力大于生產(chǎn)者，那么消費(fèi)者就必須等待生產(chǎn)者。為了解決這個(gè)問(wèn)題于是引入了生產(chǎn)者和消費(fèi)者模式。
生產(chǎn)者消費(fèi)者模式是通過(guò)一個(gè)容器（Queue）來(lái)解決生產(chǎn)者和消費(fèi)者的強(qiáng)耦合問(wèn)題。生產(chǎn)者和消費(fèi)者彼此之間不直接通訊，而通過(guò)阻塞隊(duì)列來(lái)進(jìn)行通訊，所以生產(chǎn)者生產(chǎn)完數(shù)據(jù)之后不用等待消費(fèi)者處理，直接扔給阻塞隊(duì)列，消費(fèi)者不找生產(chǎn)者要數(shù)據(jù)，而是直接從阻塞隊(duì)列里取，阻塞隊(duì)列就相當(dāng)于一個(gè)緩沖區(qū)，平衡了生產(chǎn)者和消費(fèi)者的處理能力。
上面的代碼如果不加以人工干預(yù)，本代碼將會(huì)一直執(zhí)行下去。從輸出結(jié)果來(lái)看，除了最初還有部分剩余產(chǎn)品外，后面只要產(chǎn)品生產(chǎn)出來(lái)后就被消費(fèi)了。這也是可以解釋的，因?yàn)橄M(fèi)者消費(fèi)產(chǎn)品的速度要快于生產(chǎn)者生產(chǎn)產(chǎn)品的速度。

總結(jié)

以上是生活随笔為你收集整理的python—多线程之线程之间共享数据（Queue）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。