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

二、原理圖

三、生產者和消費者
生產者：生產數據放到隊列中
消費者：從隊列中獲取數據
生產者和消費者都可以有多個
四、代碼

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

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

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。