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

二、原理圖

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

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

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

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

總結(jié)

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

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