C语言生产者与消费者问题

#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#include <semaphore.h>
#define QUEUE_SIZE 10       // 定义缓存区大小
int buffer[QUEUE_SIZE];     // 缓存区数组
int in = 0, out = 0;        // 输入和输出指针
sem_t full, empty;          // 初始化计数信号灯 
pthread_mutex_t lock;       // 声明互斥锁
// 生产者线程函数
void *producer(void *arg){
    while (1) {
        int new_item = some_producing_function(); // 生成新产品的函数
        sem_wait(&empty);   // 降低 empty 的值，等待可用缓存空间
        pthread_mutex_lock(&lock); // 加锁
        buffer[in] = new_item;  // 写入缓存区
        in = (in + 1) % QUEUE_SIZE; // 更新输入队列指针
        printf("Produced %d\n", new_item);
        pthread_mutex_unlock(&lock); // 解锁
        sem_post(&full);             // 提高 full 的值，增加可消费产品数量 
        sleep(2);   // 随机等待一段时间, 然后再生产下一个数据
    }
}
// 消费者线程函数
void *consumer(void *arg){
    while (1) {      
        sem_wait(&full);  //减小 full 的值，等待有可消费的产品       
        pthread_mutex_lock(&lock); //加锁
        int consumed_item = buffer[out]; // 从缓存区读取
        out = (out+1) % QUEUE_SIZE; // 更新输出队列指针
        printf("Consumed %d\n", consumed_item);
        pthread_mutex_unlock(&lock);  //解锁
        sem_post(&empty);  //提高 empty 的值，增加可用空间
        sleep(3); // 等待一段时间再进行下一次消费操作
    }
}
int main(int argc, char const **argv) 
{
    sem_init(&empty, 0, QUEUE_SIZE);  //初始化 empty信号灯，用于追踪缓存区为空的使用情况。其初始值为缓存队列的大小
    sem_init(&full, 0, 0);    // full信号灯 跟踪有多少产品已经被生产
    pthread_mutex_init(&lock, NULL);  // 初始化互斥锁
    pthread_t producer_thread, consumer_thread;
    pthread_create(&producer_thread, NULL, &producer, NULL); //启动生产者线程
    pthread_create(&consumer_thread, NULL, &consumer, NULL); //启动消费者线程
    pthread_join(producer_thread, NULL);
    pthread_join(consumer_thread, NULL);
    sem_destroy(&empty);  // 销毁两个信号灯
    sem_destroy(&full);
    pthread_mutex_destroy(&lock); //销毁 mutex 执行完成之后
    return 0;
}