生产者和消费者问题详解

清疚 2022-07-10 15:58 274阅读 0赞

# 定义 #

生产者消费者问题（英语：Producer-consumer problem），也称有限缓冲问题（英语：Bounded-buffer problem），是一个多线程同步问题的经典案例。该问题描述了共享固定大小缓冲区的两个线程——即所谓的“生产者”和“消费者”——在实际运行时会发生的问题。生产者的主要作用是生成一定量的数据放到缓冲区中，然后重复此过程。与此同时，消费者也在缓冲区消耗这些数据。该问题的关键就是要保证生产者不会在缓冲区满时加入数据，消费者也不会在缓冲区中空时消耗数据。

# 思路 #

要解决该问题，就必须让生产者在缓冲区满时休眠（要么干脆就放弃数据），等到下次消费者消耗缓冲区中的数据的时候，生产者才能被唤醒，开始往缓冲区添加数据。同样，也可以让消费者在缓冲区空时进入休眠，等到生产者往缓冲区添加数据之后，再唤醒消费者。通常采用进程间通信的方法解决该问题，常用的方法有信号灯法\[1\]等。如果解决方法不够完善，则容易出现死锁的情况。出现死锁时，两个线程都会陷入休眠，等待对方唤醒自己。该问题也能被推广到多个生产者和消费者的情形。

# java实现 #

## 使用信号灯的算法 ##

信号灯可以避免上述唤醒指令不起作用的情况。该方法（见下面的代码）使用了两个信号灯，fillCount 和 emptyCount。fillCount 用于记录缓冲区中将被读取的数据项数（实际上就是有多少数据项在缓冲区里），emptyCount 用于记录缓冲区中空闲空间数。当有新数据项被放入缓冲区时，fillCount 增加，emptyCount 减少。如果在生产者尝试减少 emptyCount 的时候发现其值为零，那么生产者就进入休眠。等到有数据项被消耗，emptyCount 增加的时候，生产者才被唤醒。消费者的行为类似。

semaphore fillCount = 0; // 生产的项目
    semaphore emptyCount = BUFFER_SIZE; // 剩余空间
    
    procedure producer() { while (true) { item = produceItem(); down(emptyCount); putItemIntoBuffer(item); up(fillCount); } } procedure consumer() { while (true) { down(fillCount); item = removeItemFromBuffer(); up(emptyCount); consumeItem(item); } }

上述方法在只有一个生产者和一个消费者时能解决问题。对于多个生产者或者多个消费者共享缓冲区的情况，该算法也会导致竞争条件，出现两个或以上的线程同时读或写同一个缓冲区槽的情况。为了说明这种情况是如何发生的，可以假设 putItemIntoBuffer() 的一种可能的实现：先寻找下一个可用空槽，然后写入数据项。下列情形是可能出现的：  
两个生产者都减少 emptyCount 的值；  
某一生产者寻找到下一个可用空槽；  
另一生产者也找到了下一个可用空槽，结果和上一步被找到的是同一个空槽；  
两个生产者向可用空槽写入数据。

## 多个生产者和消费者的问题 ##

为了解决这个问题，需要在保证同一时刻只有一个生产者能够执行 putItemIntoBuffer()。也就是说，需要寻找一种方法来互斥地执行临界区的代码。为了达到这个目的，可引入一个二值信号灯 mutex，其值只能为 1 或者 0。如果把线程放入 down(mutex) 和 up(mutex) 之间，就可以限制只有一个线程能被执行。多生产者、消费者的解决算法如下：

semaphore mutex = 1;
    semaphore fillCount = 0;
    semaphore emptyCount = BUFFER_SIZE;
    
    
    procedure producer() { while (true) { item = produceItem(); down(emptyCount); down(mutex); putItemIntoBuffer(item); up(mutex); up(fillCount); } } procedure consumer() { while (true) { down(fillCount); down(mutex); item = removeItemFromBuffer(); up(mutex); up(emptyCount); consumeItem(item); } }

# c语言的经典解法 #

## 问题分析 ##

1) 关系分析。生产者和消费者对缓冲区互斥访问是互斥关系，同时生产者和消费者又是一个相互协作的关系，只有生产者生产之后，消费者才能消费，他们也是同步关系。

2) 整理思路。这里比较简单，只有生产者和消费者两个进程，正好是这两个进程存在着互斥关系和同步关系。那么需要解决的是互斥和同步PV操作的位置。

3) 信号量设置。信号量mutex作为互斥信号量，它用于控制互斥访问缓冲池，互斥信号量初值为1；信号量full用于记录当前缓冲池中“满”缓冲区数，初值为0。信号量empty 用于记录当前缓冲池中“空”缓冲区数，初值为n。

生产者-消费者进程的描述如下：

semaphore mutex=1; //临界区互斥信号量
    semaphore empty=n; //空闲缓冲区
    semaphore full=0; //缓冲区初始化为空
    producer () {
       //生产者进程
        while(1){
            produce an item in nextp; //生产数据
            P(empty); //获取空缓冲区单元
            P(mutex); //进入临界区.
            add nextp to buffer; //将数据放入缓冲区
            V(mutex); //离开临界区,释放互斥信号量
            V(full); //满缓冲区数加1
        }
    }
    consumer () { //消费者进程
        while(1){
            P(full); //获取满缓冲区单元
            P(mutex); // 进入临界区
            remove an item from buffer; //从缓冲区中取出数据
            V (mutex); //离开临界区，释放互斥信号量
            V (empty) ; //空缓冲区数加1
            consume the item; //消费数据
        }
    }

# 复杂的生产者和消费者问题 #

## 问题描述 ##

桌子上有一只盘子，每次只能向其中放入一个水果。爸爸专向盘子中放苹果，妈妈专向盘子中放橘子，儿子专等吃盘子中的橘子，女儿专等吃盘子中的苹果。只有盘子为空时，爸爸或妈妈就可向盘子中放一个水果；仅当盘子中有自己需要的水果时，儿子或女儿  
可以从盘子中取出。

## 问题分析 ##

1) 关系分析。这里的关系稍复杂一些，首先由每次只能向其中放入一只水果可知爸爸和妈妈是互斥关系。爸爸和女儿、妈妈和儿子是同步关系，而且这两对进程必须连起来，儿子和女儿之间没有互斥和同步关系，因为他们是选择条件执行，不可能并发，如图2-8所示。

2) 整理思路。这里有4个进程，实际上可以抽象为两个生产者和两个消费者被连接到大小为1的缓冲区上。

3) 信号量设置。首先设置信号量plate为互斥信号量，表示是否允许向盘子放入水果，初值为1，表示允许放入，且只允许放入一个。信号量 apple表示盘子中是否有苹果，初值为0，表示盘子为空，不许取，若apple=l可以取。信号量orange表示盘子中是否有橘子，初值为0，表示盘子为空，不许取，若orange=l可以取。解决该问题的代码如下：

semaphore plate=l, apple=0, orange=0;
    dad() {  //父亲进程
        while (1) {
            prepare an apple;
            P(plate) ;  //互斥向盘中取、放水果
            put the apple on the plate;  //向盘中放苹果
            V(apple);  //允许取苹果
        }
    }
    mom() {  // 母亲进程
        while(1) {
            prepare an orange;
            P(plate);  //互斥向盘中取、放水果
            put the orange on the plate;  //向盘中放橘子
            V(orange); //允许取橘子
        }
    }
    son(){  //儿子进程
        while(1){
            P(orange) ;  //互斥向盘中取橘子
            take an orange from the plate;
            V(plate);  //允许向盘中取、放水果
            eat the orange;
        }
    }
    daughter () {  //女儿进程
        while(1) {
            P(apple);  // 互斥向盘中取苹果
            take an apple from the plate;
            V(plate);  //运行向盘中取、放水果
            eat the apple;
        }
    }