一、什么是生產(chǎn)者消費者模型？

生產(chǎn)者就是生產(chǎn)數(shù)據(jù)的線程，消費者指的就是消費數(shù)據(jù)的線程。

在多線程開發(fā)過程中，生產(chǎn)者的速度比消費者的速度快，那么生產(chǎn)者就必須等待消費者把數(shù)據(jù)處理完，生產(chǎn)者才會產(chǎn)生新的數(shù)據(jù)，相對的，如果消費者處理數(shù)據(jù)的速度大于生產(chǎn)者，那么消費者就必須等待生產(chǎn)者。

為了解決這種問題，就有了生產(chǎn)者消費者模型。

生產(chǎn)者與消費者模型，是通過一個容器，來解決生產(chǎn)者和消費者之間的耦合性問題，生產(chǎn)者和消費者之間并不會直接通信，這樣生產(chǎn)者就無需等待消費者處理完數(shù)據(jù)，生產(chǎn)者可以直接把數(shù)據(jù)扔給隊列，這個時候消費者也無需找生產(chǎn)者要數(shù)據(jù)，直接去隊列中取數(shù)據(jù)，這個隊列，起到的就是一個緩沖區(qū)的作用，具有平衡生產(chǎn)者和消費者的處理能力。

二、基于隊列的生產(chǎn)者消費者模型的示例。

ver1：

#!/usr/local/bin/python2.7

# -*- coding:utf-8 -*-

import time

import random

import Queue

import threading

q1 = Queue.Queue()

def producer(name):

? ? count = 0

? ? while count < 10:

? ? ? ? print ?"making..."

? ? ? ? time.sleep(random.randrange(3))

? ? ? ? q1.put(count)

? ? ? ? print "procucer %s has produced %s baozi...." %(name,count)

? ? ? ? count += 1

? ? ? ? print "ok!"

def consumer(name):

? ? count = 0

? ? while count < 10:

? ? ? ? time.sleep(random.randrange(4))

? ? ? ? if not q1.empty():

? ? ? ? ? ? data = q1.get()

? ? ? ? ? ? print data

? ? ? ? ? ? print '\033[32;1mConsumer %s has eat %s baozi...\033[0m' %(name, data)

? ? ? ? else:

? ? ? ? ? ? print "not fond baozi"

? ? ? ? count += 1

if __name__ == '__main__':

? ? p1 = threading.Thread(target=producer,args=('A',))

? ? c1 = threading.Thread(target=consumer,args=('B',))

? ? p1.start()

? ? c1.start()

ver2：

#!/usr/local/bin/python2.7

# -*- coding:utf-8 -*-

import time

import random

import Queue

import threading

q1 = Queue.Queue()

def producer(name):

? ? count = 0

? ? while count < 10:

? ? ? ? print ?"making..."

? ? ? ? time.sleep(random.randrange(3))

? ? ? ? q1.put(count)

? ? ? ? print "procucer %s has produced %s baozi...." %(name,count)

? ? ? ? count += 1

? ? ? ? q1.task_done() ?#給隊列發(fā)個信號,告訴隊列put完畢

? ? ? ? #q1.join()

? ? ? ? print "ok!"

def consumer(name):

? ? count = 0

? ? while count < 10:

? ? ? ? q1.join() ##監(jiān)聽生產(chǎn)者發(fā)送給隊列的信號

? ? ? ? time.sleep(random.randrange(4))

? ? ? ?# if not q1.empty():

? ? ? ? data = q1.get()

? ? ? ? #q1.task_done()

? ? ? ? print data

? ? ? ? print '\033[32;1mConsumer %s has eat %s baozi...\033[0m' %(name, data)

? ? ? ? #else:

? ? ? ? #print "not fond baozi"

? ? ? ? count += 1

if __name__ == '__main__':

? ? p1 = threading.Thread(target=producer,args=('A',))

? ? c1 = threading.Thread(target=consumer,args=('B',))

? ? c2 = threading.Thread(target=consumer,args=('C',))

? ? c3 = threading.Thread(target=consumer,args=('D',))

? ? p1.start()

? ? c1.start()

? ? c2.start()

? ? c3.start()

轉(zhuǎn)載于:https://blog.51cto.com/suhaozhi/1925548

總結(jié)

以上是生活随笔為你收集整理的11.python并发入门（part8 基于线程队列实现生产者消费者模型）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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