1、隊列Queue：

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

2、創建一個隊列

q = queue.Queue(1000) 創建一個先進先出的隊列
q=queue.LifoQueue 創建一個后進先出的隊列
q=queue.PriorityQueue 優先級的隊列

3、隊列Queue中包含的方法

Queue.qsize()：返回隊列的大小；
Queue.empty()：如果隊列為空，返回True,反之False；
Queue.full()：如果隊列滿了，返回True,反之False；
Queue.full()：與maxsize 大小對應
Queue.get([block[，timeout]])：獲取隊列,timeout等待時間
Queue.get_nowait()：相當Queue.get(False)
Queue.put(item)寫入隊列，timeout等待時間
Queue.put_nowait(item)：相當Queue.put(item，False)
Queue.taskdone()：在完成一項工作之后，Queue.taskdone()函數向任務已經完成的隊列發送一個信號
Queue.join()：實際上意味著等到隊列為空，再執行別的操作

4、生產者和消費者

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

生產者就是生產數據放到隊列中
消費者就是從隊列中獲取數據
生產者和消費者都可以有多個

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

總結

以上是生活随笔為你收集整理的多线程通信—生产者和消费者模式的全部內容，希望文章能夠幫你解決所遇到的問題。

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