基于环形队列的生产消费者模型

Linux线程同步机制

在Linux中，生产者消费者模型通常借助互斥锁（mutex）和条件变量（condition variable）实现线程安全。互斥锁保护共享数据，条件变量用于等待和唤醒线程。下面给出一个基于环形队列的C语言实现示例：

    #include #define QUEUE_SIZE 10typedef struct {    int buf[QUEUE_SIZE];    int head, tail;    pthread_mutex_t lock;    pthread_cond_t notfull, notempty;} ring_queue;void queue_init(ring_queue *q) {    q->head = q->tail = 0;    pthread_mutex_init(&q->lock, NULL);    pthread_cond_init(&q->notfull, NULL);    pthread_cond_init(&q->notempty, NULL);}void put(ring_queue *q, int val) {    pthread_mutex_lock(&q->lock);    while ((q->tail + 1) % QUEUE_SIZE == q->head)        pthread_cond_wait(&q->notfull, &q->lock);    q->buf[q->tail] = val;    q->tail = (q->tail + 1) % QUEUE_SIZE;    pthread_cond_signal(&q->notempty);    pthread_mutex_unlock(&q->lock);}int get(ring_queue *q) {    pthread_mutex_lock(&q->lock);    while (q->head == q->tail)        pthread_cond_wait(&q->notempty, &q->lock);    int val = q->buf[q->head];    q->head = (q->head + 1) % QUEUE_SIZE;    pthread_cond_signal(&q->notfull);    pthread_mutex_unlock(&q->lock);    return val;}  

上述代码中，put和get分别对应生产者和消费者操作。当队列满或空时，线程会等待相应条件变量，避免忙等待浪费CPU。

无锁编程的思考

除了基于锁的实现，还可以利用原子操作设计无锁环形队列，进一步提升性能。但无锁编程复杂度高，需谨慎处理内存序。本文介绍的加锁方法已能满足大多数应用，且易于理解和调试。

总结

本文详细介绍了如何在Linux下利用环形队列实现生产者消费者模型，并展示了互斥锁与条件变量的用法。掌握这些并发编程基础，对于编写高效稳定的多线程程序至关重要。读者可尝试扩展代码，如增加多生产者多消费者支持，或改用信号量实现。

关键词：环形队列、生产者消费者模型、Linux线程同步、并发编程