linux学习进展 线程同步——条件变量

在前面的学习中我们掌握了互斥锁和读写锁它们主要解决线程间的资源竞争问题保证临界区的独占或共享访问。但在实际开发中我们常会遇到这样的场景线程需要等待某个“条件满足”后才能执行比如消费者等待缓冲区有数据、生产者等待缓冲区有空位此时仅用锁无法高效实现——若线程循环加锁检查条件会造成CPU资源的浪费忙等待。而条件变量Condition Variable正是为解决这一问题而生它与互斥锁配合使用构成“等待-通知”模型让线程在条件不满足时主动阻塞条件满足时被唤醒高效实现线程间的协同同步。一、条件变量的核心概念条件变量本身不是锁而是一种线程间的“通知机制”核心作用是让线程在某个条件不满足时主动放弃CPU并阻塞等待直到其他线程修改条件并发出通知再唤醒该线程继续执行。条件变量的核心设计初衷的是避免“忙等待”如果没有条件变量线程只能通过“循环加锁→检查条件→解锁”的方式等待条件满足这会持续占用CPU资源而条件变量能让线程在条件不满足时进入阻塞状态释放CPU直到被唤醒极大提升了系统资源利用率。条件变量的使用有一个核心前提必须与互斥锁配合使用。原因很简单条件的判断和修改依赖共享资源比如缓冲区的空满状态互斥锁用于保护这些共享资源确保条件检查与修改的原子性避免出现竞态条件同时条件变量的等待和唤醒操作也需要与互斥锁的加锁、解锁配合才能保证同步逻辑的安全性。简单总结互斥锁解决“资源独占”问题条件变量解决“线程有序等待”问题二者协同工作实现高效、安全的线程同步。二、条件变量与互斥锁、读写锁的区别为了更清晰地定位条件变量的作用我们对比它与之前学习的互斥锁、读写锁的核心差异明确各自的适用场景特性互斥锁mutex读写锁rwlock条件变量cond核心作用保证临界区独占访问解决资源竞争区分读写操作实现读共享、写独占提升并发效率实现线程间“等待-通知”避免忙等待实现线程协同本质独占锁共享-独占锁通知机制非锁是否依赖其他锁独立使用独立使用必须与互斥锁配合使用适用场景读少写多、读写频率相近读多写少线程需等待某个条件满足如生产者-消费者模型三、条件变量的常用APILinux系统Linux中条件变量的相关操作均定义在pthread.h头文件中核心API分为4类初始化、等待、通知、销毁。条件变量的变量类型为pthread_cond_t且所有API的返回值均为成功返回0失败返回非0错误码。1. 初始化条件变量条件变量有两种初始化方式静态初始化和动态初始化可根据变量的定义位置全局/局部选择合适的方式。// 1. 静态初始化推荐适用于全局或静态变量 // 无需手动销毁系统自动回收资源 pthread_cond_t cond PTHREAD_COND_INITIALIZER; // 2. 动态初始化适用于局部变量或动态分配的变量 // 需要手动销毁避免资源泄漏 int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);参数说明cond指向条件变量的指针用于操作当前条件变量attr条件变量的属性通常设为NULL使用默认属性一般开发中无需自定义属性注意动态初始化的条件变量必须在使用完成后手动销毁否则会造成资源泄漏。2. 等待条件满足核心API等待条件变量的API有两个版本普通阻塞版本和带超时的阻塞版本核心功能是让当前线程在条件不满足时阻塞释放CPU资源。// 1. 普通阻塞版本等待条件满足直到被唤醒 int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex); // 2. 带超时版本等待指定时间若仍未被唤醒则返回错误 int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex, const struct timespec *restrict abstime);核心说明重点中的重点调用pthread_cond_wait前当前线程必须已经持有互斥锁即已调用pthread_mutex_lock函数执行时会自动完成两个原子操作① 释放互斥锁② 让当前线程阻塞在条件变量上。这两个操作是原子的避免了“线程释放锁后、阻塞前”被其他线程修改条件的竞态问题当线程被唤醒通过pthread_cond_signal或pthread_cond_broadcast后会自动重新获取互斥锁然后从pthread_cond_wait函数返回继续执行后续代码带超时版本pthread_cond_timedwait的abstime参数是“绝对时间”如当前时间3秒超时后会返回错误码ETIMEDOUT避免线程永久阻塞。3. 通知线程唤醒等待线程当条件满足时通过以下两个API唤醒等待在条件变量上的线程分为“唤醒一个”和“唤醒所有”两种场景。// 1. 唤醒至少一个等待在该条件变量上的线程随机唤醒一个 int pthread_cond_signal(pthread_cond_t *cond); // 2. 唤醒所有等待在该条件变量上的线程 int pthread_cond_broadcast(pthread_cond_t *cond);使用说明调用通知API时建议在“持有互斥锁、修改条件后”调用确保条件修改的原子性避免线程被唤醒后条件又被其他线程修改pthread_cond_signal效率更高适用于“只需要一个线程处理条件”的场景如单一消费者pthread_cond_broadcast适用于“多个线程需要响应条件”的场景如多个消费者等待数据避免线程饥饿。4. 销毁条件变量仅动态初始化的条件变量需要手动销毁静态初始化的条件变量无需销毁系统会自动回收。销毁前必须确保所有等待该条件变量的线程都已被唤醒并退出否则会返回错误EBUSY。int pthread_cond_destroy(pthread_cond_t *cond);注意销毁条件变量后不可再对其进行任何操作如等待、通知否则会导致未定义行为如程序崩溃。四、条件变量的核心使用模板必背条件变量的使用有固定模板分为“等待线程”和“通知线程”两部分核心是“互斥锁保护条件、循环检查条件、通知后唤醒”具体模板如下1. 等待线程需等待条件满足才能执行// 1. 加互斥锁保护条件变量和共享资源 pthread_mutex_lock(mutex); // 2. 循环检查条件重点用while而非if // 原因避免“虚假唤醒”——即使没有线程通知等待线程也可能被唤醒 while (条件不满足) { // 3. 条件不满足阻塞等待自动释放互斥锁 pthread_cond_wait(cond, mutex); } // 4. 条件满足执行临界区操作访问共享资源 // ... 业务逻辑 ... // 5. 解锁互斥锁 pthread_mutex_unlock(mutex);2. 通知线程修改条件后唤醒等待线程// 1. 加互斥锁保护条件变量和共享资源 pthread_mutex_lock(mutex); // 2. 修改条件关键必须在互斥锁保护下修改 条件 满足状态; // 3. 唤醒等待线程根据场景选择signal或broadcast pthread_cond_signal(cond); // 唤醒一个线程 // pthread_cond_broadcast(cond); // 唤醒所有线程 // 4. 解锁互斥锁建议在通知后解锁避免线程唤醒后立即阻塞 pthread_mutex_unlock(mutex);五、实战案例用条件变量实现生产者-消费者模型生产者-消费者模型是条件变量最典型的应用场景生产者线程生产数据放入缓冲区消费者线程从缓冲区取出数据消费当缓冲区满时生产者阻塞等待当缓冲区空时消费者阻塞等待。我们用条件变量互斥锁实现该模型直观理解条件变量的使用流程。案例代码#include pthread.h #include stdio.h #include stdlib.h #include unistd.h // 定义缓冲区大小 #define BUFFER_SIZE 5 // 缓冲区存储生产的整数数据 int buffer[BUFFER_SIZE]; // 缓冲区计数当前数据个数 int count 0; // 互斥锁保护缓冲区和count变量 pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER; // 条件变量1缓冲区不满生产者等待 pthread_cond_t cond_not_full PTHREAD_COND_INITIALIZER; // 条件变量2缓冲区非空消费者等待 pthread_cond_t cond_not_empty PTHREAD_COND_INITIALIZER; // 生产者线程函数生产数据放入缓冲区 void *producer(void *arg) { int tid *(int *)arg; for (int i 0; i 10; i) { // 生产10个数据 // 加互斥锁 pthread_mutex_lock(mutex); // 循环检查缓冲区是否满满则阻塞等待 while (count BUFFER_SIZE) { printf(生产者%d缓冲区已满等待消费者消费...\n, tid); pthread_cond_wait(cond_not_full, mutex); } // 生产数据放入缓冲区 buffer[count] i; printf(生产者%d生产数据%d当前缓冲区数据个数%d\n, tid, i, count); // 通知消费者缓冲区非空可以消费 pthread_cond_signal(cond_not_empty); // 解锁互斥锁 pthread_mutex_unlock(mutex); // 模拟生产耗时1秒 sleep(1); } return NULL; } // 消费者线程函数从缓冲区取出数据消费 void *consumer(void *arg) { int tid *(int *)arg; while (1) { // 循环消费 // 加互斥锁 pthread_mutex_lock(mutex); // 循环检查缓冲区是否空空则阻塞等待 while (count 0) { printf(消费者%d缓冲区为空等待生产者生产...\n, tid); pthread_cond_wait(cond_not_empty, mutex); } // 消费数据从缓冲区取出 int data buffer[--count]; printf(消费者%d消费数据%d当前缓冲区数据个数%d\n, tid, data, count); // 通知生产者缓冲区不满可以生产 pthread_cond_signal(cond_not_full); // 解锁互斥锁 pthread_mutex_unlock(mutex); // 模拟消费耗时1秒 sleep(1); } return NULL; } int main() { pthread_t prod_tid, cons_tid; int prod_id 1, cons_id 1; // 创建生产者线程和消费者线程 pthread_create(prod_tid, NULL, producer, prod_id); pthread_create(cons_tid, NULL, consumer, cons_id); // 等待线程结束实际中消费者为死循环需手动终止 pthread_join(prod_tid, NULL); pthread_join(cons_tid, NULL); // 销毁互斥锁和条件变量静态初始化可省略但写了更规范 pthread_mutex_destroy(mutex); pthread_cond_destroy(cond_not_full); pthread_cond_destroy(cond_not_empty); return 0; }编译与运行编译时需链接pthread线程库Linux下线程库默认不自动链接命令如下gcc cond_demo.c -o cond_demo -lpthread ./cond_demo运行结果分析从运行结果中可清晰看到条件变量的“等待-通知”逻辑生产者线程先生产数据当缓冲区满count5时调用pthread_cond_wait阻塞释放互斥锁让消费者线程执行消费者线程消费数据后调用pthread_cond_signal唤醒生产者生产者被唤醒后重新获取互斥锁继续生产当缓冲区空count0时消费者线程阻塞等待生产者生产后唤醒整个过程中互斥锁保护缓冲区和count变量避免竞态条件条件变量避免了线程忙等待提升CPU利用率。六、条件变量的常见错误与避坑要点忘记与互斥锁配合使用调用pthread_cond_wait前未加互斥锁或未在互斥锁保护下修改条件会导致竞态条件如线程检查条件后条件被其他线程修改程序可能出现异常。用if代替while检查条件这是最常见的错误由于条件变量存在“虚假唤醒”即使没有线程通知等待线程也可能被唤醒若用if检查条件线程被虚假唤醒后会直接执行临界区操作导致逻辑错误必须用while循环确保线程被唤醒后再次检查条件是否真的满足。解锁顺序不当若先解锁互斥锁再调用pthread_cond_signal可能导致线程被唤醒后互斥锁已被其他线程获取从而立即阻塞影响程序效率正确做法是先修改条件再调用通知API最后解锁互斥锁。销毁正在被使用的条件变量若还有线程在等待该条件变量就调用pthread_cond_destroy会返回错误EBUSY甚至导致程序崩溃销毁前必须确保所有等待线程都已退出。滥用pthread_cond_broadcast盲目使用pthread_cond_broadcast唤醒所有线程会导致多个线程同时竞争互斥锁产生“惊群效应”浪费CPU资源仅在需要多个线程响应条件时使用否则优先用pthread_cond_signal。忽略超时机制在实际开发中若仅用pthread_cond_wait阻塞等待可能因通知丢失导致线程永久阻塞关键场景下建议使用pthread_cond_timedwait设置超时时间避免线程“卡死”。七、总结条件变量是Linux线程同步中核心的“等待-通知”机制它本身不具备互斥能力必须与互斥锁配合使用核心作用是避免线程忙等待提升系统资源利用率适用于“线程需等待某个条件满足”的场景如生产者-消费者、线程池任务调度等。核心要点回顾条件变量的核心是“等待-通知”解决线程有序协同问题依赖互斥锁保护条件和共享资源核心API初始化init/静态初始化、等待wait/timedwait、通知signal/broadcast、销毁destroy使用模板等待线程“加锁→循环检查条件→等待→执行→解锁”通知线程“加锁→修改条件→通知→解锁”避坑重点用while检查条件、与互斥锁配合、正确的解锁顺序、避免滥用broadcast。至此我们已经掌握了Linux线程同步的三种核心机制互斥锁、读写锁、条件变量。下一节我们将学习线程同步的其他补充机制以及实际开发中的同步场景选型技巧。