生产者-消费者问题

核心概念

生产者-消费者问题是一个经典的多线程同步模型，描述两类线程（生产者和消费者）通过共享缓冲区协作的过程：

• 生产者：生成数据并放入缓冲区
• 消费者：从缓冲区取出数据并处理
• 缓冲区：固定容量的共享队列（需线程安全）

关键挑战

1. 缓冲区同步：
   • 缓冲区满时，生产者必须等待
   • 缓冲区空时，消费者必须等待
2. 线程安全：防止多个线程同时修改缓冲区导致数据错误

解决方案（使用信号量）

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

#define BUFFER_SIZE 10

sem_t empty;   // 空槽位数量（初始=缓冲区大小）
sem_t full;    // 满槽位数量（初始=0）
pthread_mutex_t mutex;  // 互斥锁
int buffer[BUFFER_SIZE];
int in = 0, out = 0;

// 生产者线程
void* producer(void* arg) {
    while (1) {
        int 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) {
    while (1) {
        sem_wait(&full);            // 等待满槽位
        pthread_mutex_lock(&mutex); // 进入临界区

        int item = buffer[out];     // 取出数据
        out = (out + 1) % BUFFER_SIZE;

        pthread_mutex_unlock(&mutex);
        sem_post(&empty);           // 增加空槽位

        consume_item(item);         // 消费数据
    }
}

关键机制说明

1. 信号量（Semaphore）：

   • empty：控制生产者可用槽位（初始=缓冲区容量）
   • full：控制消费者可用数据（初始=0）

2. 互斥锁（Mutex）：

   • 保护缓冲区操作（in/out指针修改）的原子性

3. 等待/唤醒机制：

   • sem_wait()：资源不足时阻塞线程
   • sem_post()：释放资源并唤醒等待线程

典型应用场景

1. 消息队列系统（如Kafka、RabbitMQ）
2. 任务调度池（线程池任务分配）
3. 数据流水线处理（图像/视频处理框架）
4. 打印任务队列

注意：现代编程语言通常提供高级封装（如Java的BlockingQueue、Python的queue.Queue），可直接使用线程安全队列，简化实现。