目录一、互斥锁的本质是什么二、条件变量与互斥锁的差异1为什么条件变量往往比互斥锁更加高效2消费者生产者模型中的条件变量3总结三、惊群效应与虚假唤醒的解决方案1虚假唤醒2惊群效应3示例代码在编写Linux上位机时需要用到多线程、条件变量、互斥锁等知识却发现自己没有明晰互斥锁和条件变量的差异一直是把他们当做同一种东西在使用本篇文章将从源码伪代码的角度具体分析并说明惊群效应、虚假唤醒等问题。一、互斥锁的本质是什么在学Linux文件操作时我们曾提到一切皆文件思想即所有的外设硬件资源、软件资源都会被抽象成一个结构体先描述后管理当你进行访问、修改等操作时本质是先创建一个文件这个文件中存储的就是该结构体然后对该文件进行读写操作。尤其注意到阻塞读操作---read当read的缓冲区中没有任何数据时会将该线程链入当前文件的阻塞队列中直到该资源就绪唤醒阻塞队列的所有线程被调度器调度从而占据CPU时间片。而互斥锁是一种软件资源他也会有类似这样的结构体也会有自己的阻塞队列。即不仅外设资源有阻塞队列软件资源也会有阻塞队列除了阻塞队列外可能还有一个标志位比如置1时表示互斥锁被别人持有置0时表示没有人持有当前线程可以去竞争加锁。更重要的是互斥锁是Linux内核空间的资源这意味着每次加锁、解锁都在进行用户态到内核态的切换这个开销极大而后续的条件变量主要就是在这里进行了优化。二、条件变量与互斥锁的差异1为什么条件变量往往比互斥锁更加高效条件变量你可以理解成是互斥锁对外封装了一层增加了用户态的条件检测提高条件判断的效率。正是因为条件变量底层封装了互斥锁所以在使用的时候需要主动传递一个互斥锁参数进去。而无论是条件变量还是互斥锁在被唤醒的第一件事情就是竞争锁完整的链路如下第一次判断条件不满足被链入条件变量中的阻塞队列线程从条件变量等待队列被唤醒立刻加入互斥锁的等待队列竞争互斥锁只有抢到锁后才会回到while循环在用户态重新判断is_full()/is_empty()若条件仍不满足再次调用pthread_cond_wait原子释放锁并挂起。而这个过程中相较于互斥锁高效的关键在于一旦没有竞争到锁或者条件不满足都立马挂起直接将自己的时间片清空。而不会去忙等待白白竞争后续的锁资源最多只会在唤醒的时候竞争一次wait只要返回了就表示竞争到锁了紧接着往后判断条件是否满足2消费者生产者模型中的条件变量在消费者生产者模型中常常会使用条件变量而不是互斥锁这是因为两个线程往往都在while循环中进行单一的操作使得该线程不断竞争锁---条件不满足----解锁---循环回开头重新竞争锁。这是因为unlock后并不会立马挂起自己仅仅是通知别的线程你可以去竞争该锁了“而条件变量中的wait是一个用户态库函数它一旦被唤醒就会首先竞争锁竞争到锁之后再去用户态检查条件。如果不满足会立马原子地释放锁并将自己挂入内核等待队列。”直接防止了刚刚在时间片内无限抢夺竞争锁资源的循环(忙等待有点类似自旋锁)从而使得CPU资源分配给其他有用的线程。条件变量的进一步优化在于它能让线程在条件不满足时主动休眠而不是在锁竞争失败后一直尝试直到时间片结束才被动休眠。3总结条件变量可以说全方面是互斥锁的升级版被广泛的使用于生产者消费者模型中极大的提升了CPU的利用率。条件变量相比于互斥锁主要有两点优势1mutex解锁后不会里面挂起自己仅仅通知别人使得自己仍重复竞争锁资源造成时间片空转做了无意义的加锁解锁操作。而条件变量立马挂起防止空转。2条件变量多了一层用户态检测当线程被唤醒时首先会去判断条件成立与否在wait返回后因为wait自带竞争锁的操作虽然这里说是多了一层用户态检测但本质是软件工程师自己写的条件变量真正相较于互斥锁的优势在于原子性的解锁与挂起。所以我认为条件变量说的更多的是一种判断规则使用用户态的高效尽量减少内核态的切换只不过可能加入了原子操作。当然这些说的是古老内核中的互斥锁在Pthread库中的互斥锁借鉴了条件变量的用户态方案在无竞争时会通过用户态原子变量加解锁使得性能比内核锁更高只有在有竞争需要链入到阻塞队列时才会进入内核态开销较大。三、惊群效应与虚假唤醒的解决方案在生产者消费者模型中虽然条件变量极大地提升了性能但如果工程代码不严谨依然会遇到两个经典致命问题虚假唤醒和惊群效应。解决这两个问题是你的程序稳定运行的基石。1虚假唤醒线程调用pthread_cond_wait()等待条件变量时明明没有任何线程调用signal/broadcast唤醒它它却突然醒了。或者它被唤醒了但再次检查条件时发现条件已经不满足了比如多个消费者被同时唤醒第一个拿走了数据后面的醒来发现没货了。尤其是不能使用双层if判断只要有if就可能是历史条件匹配却没有立马竞争到锁导致中间时段的条件变化了不再匹配要求虚假唤醒可能发生N次你不可能写N层if判断。而while循环则在每次唤醒后都重新检测一下再去竞争锁直接避免了上述问题。2惊群效应当生产者生产出一个产品调用pthread_cond_broadcast()唤醒所有等待线程时所有等待的消费者都会被唤醒。但缓冲区里只有一个产品最终只有一个消费者能抢到锁并取走数据。剩下的消费者们抢到锁后发现缓冲区空了又得释放锁并回去睡觉。这就像一群猎人听到猎物信号都冲出去结果只有一个猎人抓到了兔子其他人空手而归浪费了大量体力CPU 资源和上下文切换开销。解决方案使用pthread_cond_signal()唤醒单个线程代替pthread_cond_broadcast()唤醒所有线程。signal推荐只唤醒一个正在等待该条件的线程。操作系统会从等待队列中挑一个最合适的唤醒精准且高效。broadcast慎用仅在所有线程都有必要醒来时才使用比如线程池退出、所有线程都要检查状态变化。3示例代码#include stdio.h #include stdlib.h #include pthread.h #include unistd.h #include time.h // 定义缓冲区最大容量 #define MAX_BUFFER_SIZE 5 // 定义生产者/消费者线程数量模拟多生产多消费场景 #define PRODUCER_NUM 2 #define CONSUMER_NUM 3 // 1. 定义共享资源缓冲区 互斥锁 条件变量 int buffer[MAX_BUFFER_SIZE]; // 产品缓冲区用数组模拟 int buffer_size 0; // 当前缓冲区产品数量 pthread_mutex_t mutex; // 保护缓冲区的互斥锁 // 条件变量not_empty消费者等有货、not_full生产者等有空位 pthread_cond_t not_empty; pthread_cond_t not_full; // 生产产品生成随机数模拟 int produce_product() { static int product_id 0; return product_id; // 返回唯一产品ID } // 消费产品 void consume_product(int product) { printf([消费者 %ld] 消费产品%d当前缓冲区剩余%d\n, pthread_self() % 1000, product, buffer_size); // 模拟消费耗时 usleep(rand() % 100000); } // 2. 生产者线程函数 void* producer_thread(void* arg) { int producer_id *(int*)arg; free(arg); // 释放动态分配的ID内存 while (1) { // 外层无限循环对应单片机while(1) // 步骤1加锁保护临界区 pthread_mutex_lock(mutex); // 步骤2while循环检测条件防虚假唤醒 while (buffer_size MAX_BUFFER_SIZE) { printf([生产者 %d] 缓冲区满等待空位...\n, producer_id); // 条件不满足释放锁 挂起直到被not_full唤醒 pthread_cond_wait(not_full, mutex); } // 步骤3生产产品并放入缓冲区 int product produce_product(); buffer[buffer_size] product; printf([生产者 %d] 生产产品%d当前缓冲区数量%d\n, producer_id, product, buffer_size); // 步骤4唤醒一个消费者防惊群效应 pthread_cond_signal(not_empty); // 步骤5解锁 pthread_mutex_unlock(mutex); // 模拟生产耗时避免生产过快 usleep(rand() % 200000); } return NULL; } // 3. 消费者线程函数 void* consumer_thread(void* arg) { int consumer_id *(int*)arg; free(arg); // 释放动态分配的ID内存 while (1) { // 外层无限循环 // 步骤1加锁 pthread_mutex_lock(mutex); // 步骤2while循环检测条件防虚假唤醒 while (buffer_size 0) { printf([消费者 %d] 缓冲区空等待产品...\n, consumer_id); // 条件不满足释放锁 挂起直到被not_empty唤醒 pthread_cond_wait(not_empty, mutex); } // 步骤3取出产品并消费 int product buffer[--buffer_size]; consume_product(product); // 步骤4唤醒一个生产者防惊群效应 pthread_cond_signal(not_full); // 步骤5解锁 pthread_mutex_unlock(mutex); // 模拟消费耗时 usleep(rand() % 300000); } return NULL; } // 主函数创建线程 等待线程后台服务核心 int main() { // 初始化随机数种子 srand((unsigned int)time(NULL)); // 初始化互斥锁和条件变量 pthread_mutex_init(mutex, NULL); pthread_cond_init(not_empty, NULL); pthread_cond_init(not_full, NULL); // 定义线程ID数组 pthread_t producers[PRODUCER_NUM]; pthread_t consumers[CONSUMER_NUM]; // 创建生产者线程 for (int i 0; i PRODUCER_NUM; i) { int* id malloc(sizeof(int)); *id i 1; // 生产者ID1、2... pthread_create(producers[i], NULL, producer_thread, (void*)id); } // 创建消费者线程 for (int i 0; i CONSUMER_NUM; i) { int* id malloc(sizeof(int)); *id i 1; // 消费者ID1、2、3... pthread_create(consumers[i], NULL, consumer_thread, (void*)id); } // 主线程无限阻塞后台服务不退出 while (1) { pause(); // 挂起主线程等待信号永远不退出 } // 以下代码不会执行仅演示资源释放 pthread_mutex_destroy(mutex); pthread_cond_destroy(not_empty); pthread_cond_destroy(not_full); return 0; }