使用pthread的c++中的生产者-消费者问题

#include <pthread.h>
#include <queue>

#define BUFFER_SIZE 10

std::queue<int> buffer;
pthread_mutex_t mutex;
pthread_cond_t cond_producer;
pthread_cond_t cond_consumer;

void* producer(void* arg) {
    while (true) {
        pthread_mutex_lock(&mutex);
        while (buffer.size() == BUFFER_SIZE) {
            pthread_cond_wait(&cond_producer, &mutex);
        }
        // 生产数据
        int data = rand();
        buffer.push(data);
        pthread_cond_signal(&cond_consumer);
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}

void* consumer(void* arg) {
    while (true) {
        pthread_mutex_lock(&mutex);
        while (buffer.empty()) {
            pthread_cond_wait(&cond_consumer, &mutex);
        }
        // 消费数据
        int data = buffer.front();
        buffer.pop();
        pthread_cond_signal(&cond_producer);
        pthread_mutex_unlock(&mutex);
        // 处理数据
    }
    return NULL;
}

int main() {
    pthread_t producer_thread;
    pthread_t consumer_thread;

    pthread_mutex_init(&mutex, NULL);
    pthread_cond_init(&cond_producer, NULL);
    pthread_cond_init(&cond_consumer, NULL);

    pthread_create(&producer_thread, NULL, producer, NULL);
    pthread_create(&consumer_thread, NULL, consumer, NULL);

    pthread_join(producer_thread, NULL);
    pthread_join(consumer_thread, NULL);

    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond_producer);
    pthread_cond_destroy(&cond_consumer);

    return 0;
}