进程同步之生产者-消费者问题（C++）

我会带着你远行 2021-10-01 04:44 306阅读 0赞

## 问题描述 ##

有一群生产者进程在生产产品，并将这些产品提供给消费者进程进行消费，生产者进程和消费者进程可以并发执行，在两者之间设置了一个具有n个缓冲区的缓冲池，生产者进程需要将所生产的产品放到缓冲区中（+1操作），消费者进程可以从缓冲区取走产品消费（-1操作）。  
![（6-5-0207）][6-5-0207]

## 产生问题 ##

当两者并发执行时可能出差错，如下图：  
![（6-5-0627）][6-5-0627]  
当执行生产者+1和消费者-1操作之后，缓冲区的值从10变为了11。

## 程序实例 ##

#include <stdio.h>
    #include <stdlib.h>
    #include <unistd.h>
    #include <pthread.h>
    #include <vector>
    
    pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
    
    int num = 0;
    
    void *producer(void*){
        int times = 10000000;
        while(times --){
            // pthread_mutex_lock(&mutex);
            num += 1;
            // pthread_mutex_unlock(&mutex);
        }
    }
    
    void *comsumer(void*){
        int times = 10000000;
        while(times --){
            // pthread_mutex_lock(&mutex);
            num -= 1;
            // pthread_mutex_unlock(&mutex);
        }
    }
    
    
    int main(){
        printf("Start in main function.");
        pthread_t thread1, thread2;
        pthread_create(&thread1, NULL, &producer, NULL);
        pthread_create(&thread2, NULL, &comsumer, NULL);
        pthread_join(thread1, NULL);
        pthread_join(thread2, NULL);
        printf("Print in main function: num = %d\n", num);
        return 0;
    }

[6-5-0207]: /images/20210923/2f9fe37e0c844e1b8f7f792fb10bf895.png
[6-5-0627]: /images/20210923/440f8bd31d004cada3a8783eef0bc459.png