生产者消费者一对多问题c语言

生产者-消费者问题是一个经典的并发控制问题，它涉及到两个角色：生产者和消费者。在C语言中，这个问题通常通过队列数据结构来解决，因为队列可以提供线程安全的数据交换。

1. **生产者**负责生成产品（通常是整数或其他类型的数据），放入队列的头部。当队列满时，生产者需要等待直到队列中有空间可用。
2. **消费者**从队列的尾部取出产品并处理它们。如果队列为空，消费者需要等待直到队列中有新的产品。

为了实现这个模型，你可以创建一个环形缓冲区（如` circular_buffer.h`库）作为队列，并使用互斥量（`pthread_mutex_t`）保证对队列操作的同步。这里的关键在于使用信号量（`pthread_condvar_t`）来通知生产者或消费者何时应该继续工作：

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

typedef struct {
    int capacity;
    int* buffer;
    int head; // 生产者的下一个插入位置
    int tail; // 消费者的下一个移除位置
    pthread_mutex_t mutex;
    pthread_cond_t empty;
    pthread_cond_t full;
} Buffer;

// 生产者函数
void producer(Buffer* buffer, int data) {
    // ...
}

// 消费者函数
void consumer(Buffer* buffer) {
    // ...
}

int main() {
    Buffer buffer = { /* 初始化容量、数组等 */ };
    pthread_t producer_thread, consumer_thread;
    // 创建和启动线程...
    while (1) {
        // ...生产者/消费者循环...
    }
    return 0;
}