只使用互斥锁和信号量的生产者-消费者同步(无pthread_cond)

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>

#define BUFFER_SIZE 10

int buffer[BUFFER_SIZE];
int in = 0;
int out = 0;

sem_t empty;
sem_t full;
pthread_mutex_t mutex;

void* producer(void* arg) {
    int item, i;
    for (i = 0; i < 20; i++) {
        item = i; // 生产数据

        sem_wait(&empty); // 等待空闲缓冲区
        pthread_mutex_lock(&mutex); // 获取互斥锁

        buffer[in] = item;
        in = (in + 1) % BUFFER_SIZE;
        printf("Produced: %d\n", item);

        pthread_mutex_unlock(&mutex); // 释放互斥锁
        sem_post(&full); // 增加满缓冲区计数
    }
    return NULL;
}

void* consumer(void* arg) {
    int item, i;
    for (i = 0; i < 20; i++) {
        sem_wait(&full); // 等待满缓冲区
        pthread_mutex_lock(&mutex); // 获取互斥锁

        item = buffer[out];
        out = (out + 1) % BUFFER_SIZE;
        printf("Consumed: %d\n", item);

        pthread_mutex_unlock(&mutex); // 释放互斥锁
        sem_post(&empty); // 增加空闲缓冲区计数
    }
    return NULL;
}

int main() {
    pthread_t producer_thread, consumer_thread;

    sem_init(&empty, 0, BUFFER_SIZE);
    sem_init(&full, 0, 0);
    pthread_mutex_init(&mutex, 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);

    sem_destroy(&empty);
    sem_destroy(&full);
    pthread_mutex_destroy(&mutex);

    return 0;
}