0

0

C语言中如何实现生产者消费者 C语言多线程同步与队列实现

裘德小鎮的故事

裘德小鎮的故事

发布时间:2025-08-17 12:37:01

|

301人浏览过

|

来源于php中文网

原创

生产者消费者问题的死锁可通过正确使用同步机制避免。1.始终先加互斥锁再访问共享资源,等待条件变量时自动释放锁。2.避免循环等待,确保线程不互相依赖对方释放资源。3.设置条件变量等待超时,防止无限期阻塞。此外,c语言还支持信号量、读写锁、自旋锁等同步机制,优化模型可通过减少锁竞争、使用无锁结构、调整线程数、高效队列实现及cpu缓存优化提升性能。

C语言中如何实现生产者消费者 C语言多线程同步与队列实现

生产者消费者问题,本质上就是一个多线程同步的问题,需要解决多个线程并发访问共享资源时的冲突。C语言中,我们可以用互斥锁和条件变量,结合队列来实现。

C语言中如何实现生产者消费者 C语言多线程同步与队列实现

解决方案

C语言中如何实现生产者消费者 C语言多线程同步与队列实现

核心思路是用一个队列作为缓冲区,生产者往队列里放东西,消费者从队列里取东西。互斥锁保证对队列的互斥访问,条件变量则用于线程间的通信,例如队列空了,消费者就等待,队列满了,生产者就等待。

立即学习C语言免费学习笔记(深入)”;

#include 
#include 
#include 
#include 

#define BUFFER_SIZE 5

typedef struct {
    int buffer[BUFFER_SIZE];
    int head;
    int tail;
    int count;
    pthread_mutex_t mutex;
    pthread_cond_t not_full;
    pthread_cond_t not_empty;
} Queue;

Queue* queue_create() {
    Queue* q = (Queue*)malloc(sizeof(Queue));
    if (q == NULL) {
        perror("malloc failed");
        exit(EXIT_FAILURE);
    }
    q->head = 0;
    q->tail = 0;
    q->count = 0;
    pthread_mutex_init(&q->mutex, NULL);
    pthread_cond_init(&q->not_full, NULL);
    pthread_cond_init(&q->not_empty, NULL);
    return q;
}

void queue_destroy(Queue* q) {
    pthread_mutex_destroy(&q->mutex);
    pthread_cond_destroy(&q->not_full);
    pthread_cond_destroy(&q->not_empty);
    free(q);
}

void queue_push(Queue* q, int data) {
    pthread_mutex_lock(&q->mutex);
    while (q->count == BUFFER_SIZE) {
        pthread_cond_wait(&q->not_full, &q->mutex);
    }
    q->buffer[q->tail] = data;
    q->tail = (q->tail + 1) % BUFFER_SIZE;
    q->count++;
    pthread_cond_signal(&q->not_empty);
    pthread_mutex_unlock(&q->mutex);
}

int queue_pop(Queue* q) {
    pthread_mutex_lock(&q->mutex);
    while (q->count == 0) {
        pthread_cond_wait(&q->not_empty, &q->mutex);
    }
    int data = q->buffer[q->head];
    q->head = (q->head + 1) % BUFFER_SIZE;
    q->count--;
    pthread_cond_signal(&q->not_full);
    pthread_mutex_unlock(&q->mutex);
    return data;
}

void* producer(void* arg) {
    Queue* q = (Queue*)arg;
    int i;
    for (i = 0; i < 10; ++i) {
        queue_push(q, i);
        printf("Produced: %d\n", i);
        sleep(1); // 模拟生产时间
    }
    return NULL;
}

void* consumer(void* arg) {
    Queue* q = (Queue*)arg;
    int data, i;
    for (i = 0; i < 10; ++i) {
        data = queue_pop(q);
        printf("Consumed: %d\n", data);
        sleep(2); // 模拟消费时间
    }
    return NULL;
}

int main() {
    Queue* q = queue_create();
    pthread_t producer_thread, consumer_thread;

    pthread_create(&producer_thread, NULL, producer, q);
    pthread_create(&consumer_thread, NULL, consumer, q);

    pthread_join(producer_thread, NULL);
    pthread_join(consumer_thread, NULL);

    queue_destroy(q);
    return 0;
}

如何避免生产者消费者模型的死锁?

死锁通常发生在多个线程互相等待对方释放资源的时候。在生产者消费者模型中,如果条件变量的使用不当,或者互斥锁的加锁解锁顺序错误,就可能导致死锁。

Sapling AI Content Detector
Sapling AI Content Detector

Sapling.ai推出的免费在线AI内容检测工具

下载
C语言中如何实现生产者消费者 C语言多线程同步与队列实现

例如,如果生产者在等待队列不满的条件变量时,没有释放互斥锁,那么消费者就无法访问队列,也无法使队列不满,从而导致生产者一直等待,形成死锁。

避免死锁的关键在于:

  • 正确使用互斥锁和条件变量: 始终先获取互斥锁,再访问共享资源。在等待条件变量时,互斥锁会被自动释放,并在被唤醒后重新获取。
  • 避免循环等待: 尽量避免多个线程互相等待对方释放资源。
  • 超时机制: 在等待条件变量时,可以设置超时时间,避免无限期等待。

除了互斥锁和条件变量,还有哪些C语言多线程同步机制?

除了互斥锁和条件变量,C语言中还有其他一些多线程同步机制:

  • 信号量 (Semaphores): 信号量是一种更通用的同步机制,可以用来控制对共享资源的访问数量。互斥锁可以看作是信号量的一种特殊情况(计数为1的信号量)。
  • 读写锁 (Read-Write Locks): 读写锁允许多个线程同时读取共享资源,但只允许一个线程写入共享资源。这在读多写少的场景下可以提高性能。
  • 自旋锁 (Spin Locks): 自旋锁是一种忙等待的锁,线程会不断地尝试获取锁,直到获取成功。自旋锁适用于锁的持有时间很短的场景,可以避免线程切换的开销。

选择哪种同步机制取决于具体的应用场景和性能需求。

如何优化C语言实现的生产者消费者模型?

优化生产者消费者模型可以从以下几个方面入手:

  • 减少锁的竞争: 尽量减少线程获取锁的次数和持有锁的时间。例如,可以使用批量处理的方式,一次性生产或消费多个数据,减少锁的开销。
  • 使用无锁数据结构: 在某些情况下,可以使用无锁数据结构(例如无锁队列)来避免锁的竞争。但是,无锁数据结构的实现通常比较复杂,需要仔细考虑并发安全性。
  • 调整线程数量: 生产者和消费者的线程数量需要根据实际情况进行调整。如果生产者速度快于消费者,可以增加消费者线程的数量;反之,可以增加生产者线程的数量。
  • 使用更高效的队列实现: 选择合适的队列实现也很重要。例如,可以使用循环队列来避免频繁的内存分配和释放。
  • CPU缓存优化: 考虑CPU缓存对性能的影响,尽量使线程访问的数据在同一个缓存行中,减少缓存失效的次数。

相关专题

更多
C语言变量命名
C语言变量命名

c语言变量名规则是:1、变量名以英文字母开头;2、变量名中的字母是区分大小写的;3、变量名不能是关键字;4、变量名中不能包含空格、标点符号和类型说明符。php中文网还提供c语言变量的相关下载、相关课程等内容,供大家免费下载使用。

377

2023.06.20

c语言入门自学零基础
c语言入门自学零基础

C语言是当代人学习及生活中的必备基础知识,应用十分广泛,本专题为大家c语言入门自学零基础的相关文章,以及相关课程,感兴趣的朋友千万不要错过了。

603

2023.07.25

c语言运算符的优先级顺序
c语言运算符的优先级顺序

c语言运算符的优先级顺序是括号运算符 > 一元运算符 > 算术运算符 > 移位运算符 > 关系运算符 > 位运算符 > 逻辑运算符 > 赋值运算符 > 逗号运算符。本专题为大家提供c语言运算符相关的各种文章、以及下载和课程。

348

2023.08.02

c语言数据结构
c语言数据结构

数据结构是指将数据按照一定的方式组织和存储的方法。它是计算机科学中的重要概念,用来描述和解决实际问题中的数据组织和处理问题。数据结构可以分为线性结构和非线性结构。线性结构包括数组、链表、堆栈和队列等,而非线性结构包括树和图等。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

255

2023.08.09

c语言random函数用法
c语言random函数用法

c语言random函数用法:1、random.random,随机生成(0,1)之间的浮点数;2、random.randint,随机生成在范围之内的整数,两个参数分别表示上限和下限;3、random.randrange,在指定范围内,按指定基数递增的集合中获得一个随机数;4、random.choice,从序列中随机抽选一个数;5、random.shuffle,随机排序。

579

2023.09.05

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

516

2023.09.20

c语言get函数的用法
c语言get函数的用法

get函数是一个用于从输入流中获取字符的函数。可以从键盘、文件或其他输入设备中读取字符,并将其存储在指定的变量中。本文介绍了get函数的用法以及一些相关的注意事项。希望这篇文章能够帮助你更好地理解和使用get函数 。

627

2023.09.20

c数组初始化的方法
c数组初始化的方法

c语言数组初始化的方法有直接赋值法、不完全初始化法、省略数组长度法和二维数组初始化法。详细介绍:1、直接赋值法,这种方法可以直接将数组的值进行初始化;2、不完全初始化法,。这种方法可以在一定程度上节省内存空间;3、省略数组长度法,这种方法可以让编译器自动计算数组的长度;4、二维数组初始化法等等。

595

2023.09.22

苹果官网入口直接访问
苹果官网入口直接访问

苹果官网直接访问入口是https://www.apple.com/cn/,该页面具备0.8秒首屏渲染、HTTP/3与Brotli加速、WebP+AVIF双格式图片、免登录浏览全参数等特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

10

2025.12.24

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Rust 教程
Rust 教程

共28课时 | 3.8万人学习

Kotlin 教程
Kotlin 教程

共23课时 | 2万人学习

Go 教程
Go 教程

共32课时 | 2.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号