linux 进程同步 实例

#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;
    while (1) {
        item = produce_item(); // 生产一个项目
        sem_wait(&empty);     // 等待空槽
        pthread_mutex_lock(&mutex); // 获取互斥锁
        buffer[in] = item;
        in = (in + 1) % BUFFER_SIZE;
        pthread_mutex_unlock(&mutex); // 释放互斥锁
        sem_post(&full);      // 增加满槽信号量
    }
}

void* consumer(void* arg) {
    int item;
    while (1) {
        sem_wait(&full);      // 等待满槽
        pthread_mutex_lock(&mutex); // 获取互斥锁
        item = buffer[out];
        out = (out + 1) % BUFFER_SIZE;
        pthread_mutex_unlock(&mutex); // 释放互斥锁
        sem_post(&empty);     // 增加空槽信号量
        consume_item(item);   // 消费一个项目
    }
}

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;
}