隊列(Queue)

在多個線程之間安全的交換數(shù)據(jù)信息，隊列在多線程編程中特別有用

隊列的好處：

提高雙方的效率，你只需要把數(shù)據(jù)放到隊列中，中間去干別的事情。

完成了程序的解耦性，兩者關(guān)系依賴性沒有不大。

一、隊列的類型：

1、lass queue.Queue(maxsize=0)

先進先出，后進后出

2、class queue.LifoQueue(maxsize=0)

是先進后出，后進新出規(guī)則，last in fisrt out

3、class queue.PriorityQueue(maxsize=0)

根據(jù)優(yōu)先級來取數(shù)據(jù)。存放數(shù)據(jù)的格式? : Queue.put((priority_number,data))，priority_number越小，優(yōu)先級越高，data代表存入的值

注：maxsize代表這個隊列最大能夠put的長度

二、隊列(Queue)的內(nèi)置方法

生產(chǎn)者消費者模型

并發(fā)編程中使用生產(chǎn)者和消費者模式能夠解決絕大多數(shù)并發(fā)問題。該模式通過平衡生產(chǎn)線程和消費線程的工作能力來提高程序的整體處理數(shù)據(jù)的速度。

1、為什么要使用生產(chǎn)者和消費者模式

在線程世界里，生產(chǎn)者就是生產(chǎn)數(shù)據(jù)的線程，消費者就是消費數(shù)據(jù)的線程。在多線程開發(fā)當(dāng)中，如果生產(chǎn)者處理速度很快，而消費者處理速度很慢，那么生產(chǎn)者就必須等待消費者處理完，才能繼續(xù)生產(chǎn)數(shù)據(jù)。同樣的道理，如果消費者的處理能力大于生產(chǎn)者，那么消費者就必須等待生產(chǎn)者。為了解決這個問題于是引入了生產(chǎn)者和消費者模式。

2、什么是生產(chǎn)者消費者模式

生產(chǎn)者消費者模式是通過一個容器來解決生產(chǎn)者和消費者的強耦合問題。生產(chǎn)者和消費者彼此之間不直接通訊，而通過阻塞隊列來進行通訊，所以生產(chǎn)者生產(chǎn)完數(shù)據(jù)之后不用等待消費者處理，直接扔給阻塞隊列，消費者不找生產(chǎn)者要數(shù)據(jù)，而是直接從阻塞隊列里取，阻塞隊列就相當(dāng)于一個緩沖區(qū)，平衡了生產(chǎn)者和消費者的處理能力。

3、生成者消費者模型例子

3.1、生產(chǎn)者生產(chǎn)完畢，消費者再消費例子：

3.2 邊生產(chǎn)邊消費的模型例子

3.3、流程圖

圖解：

生產(chǎn)者生產(chǎn)，消費者消費。

消費者每消費一次，都要去執(zhí)行以下task_done()方法，來告訴消費者已經(jīng)消費成功，相當(dāng)于吃完飯，消費者應(yīng)該給錢了。

消費者每消費一次，則隊列中計數(shù)器會做減1操作。

當(dāng)隊列中的計數(shù)器為0的時候，則生產(chǎn)者不阻塞，繼續(xù)執(zhí)行，不為0的時候，則阻塞，直到消費者消費完畢為止。

總結(jié)

以上是生活随笔為你收集整理的python queue 生产者 消费者_【python】-- 队列（Queue）、生产者消费者模型的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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