多任务实现方式(四)——生产者与消费者模型

拼搏现实的明天。 2023-07-05 10:14 2阅读 0赞

## 1.什么是生产者与消费者模型？ ##

一种重要的模型，基于等待/通知机制。生产者/消费者模型描述的是有一块缓冲区作为仓库，生产者可将产品放入仓库，消费者可以从仓库中取出产品。生产者/消费者模型关注的是以下几个点：  
1、生产者与消费者不能同时进行工作，形成的是互斥关系；  
2、生产者与生产者之间不能同时生产，处于互斥关系；  
3、消费者与消费者之间不能同时工作，处于互斥关系；  
4、当缓冲区之内的资源满时，生产者不能生产；  
5、当缓冲区之内的资源空时，消费者不能消费；  
6、消费者消费的速度不能超过生产者；

## 2.示例 ##

**原代码：**

from queue import Queue
    from threading import Thread
    import time
    #创建队列
    q = Queue(10)
    
    def producer(name):
        """生产者"""
        count = 1#给生产的包子计数
        while True:
            q.join()#等待task_done()发送信号
            q.put(count)
            print("%s正在生产第%d个包子"%(name,count))
            count+=1
            time.sleep(2)
    
    def customer(name):
        count = 1
        while True:
            bao_zi = q.get()
            print("消费者%s正在吃第%d个包子"%(name,bao_zi))
            count+=1
            q.task_done()#取完后发送信号
            time.sleep(1)
    
    if __name__ == '__main__':
        t1 = Thread(target=producer,args=("刘大厨",))
        t2=Thread(target=customer,args=("翠花",))
        t1.start()
        t2.start()

**运行结果：**

刘大厨正在生产第1个包子
    消费者翠花正在吃第1个包子
    刘大厨正在生产第2个包子
    消费者翠花正在吃第2个包子
    刘大厨正在生产第3个包子
    消费者翠花正在吃第3个包子
    刘大厨正在生产第4个包子
    消费者翠花正在吃第4个包子
    刘大厨正在生产第5个包子
    消费者翠花正在吃第5个包子
    消费者翠花正在吃第6个包子
    刘大厨正在生产第6个包子
    刘大厨正在生产第7个包子
    消费者翠花正在吃第7个包子
    刘大厨正在生产第8个包子
    消费者翠花正在吃第8个包子
    刘大厨正在生产第9个包子
    消费者翠花正在吃第9个包子
    刘大厨正在生产第10个包子
    消费者翠花正在吃第10个包子
    消费者翠花正在吃第11个包子
    刘大厨正在生产第11个包子
    刘大厨正在生产第12个包子
    消费者翠花正在吃第12个包子
    刘大厨正在生产第13个包子
    消费者翠花正在吃第13个包子
    刘大厨正在生产第14个包子
    消费者翠花正在吃第14个包子
    消费者翠花正在吃第15个包子
    刘大厨正在生产第15个包子
    刘大厨正在生产第16个包子
    消费者翠花正在吃第16个包子