C语言多线程同步实战：从竞态到协同的四种武器

1. 多线程售票问题竞态条件的典型场景想象一下春运期间的火车站售票窗口4个售票员同时售卖20张车票。如果缺乏有效的管理机制很可能出现同一张票被重复售卖或者票数统计出错的情况。这个场景完美模拟了多线程编程中最经典的竞态条件问题。在实际编码中我们常常会遇到类似的情况。比如下面这个模拟售票的C语言程序#includestdio.h #includestdlib.h #includepthread.h int ticket_sum 20; // 总票数 void *sell_ticket(void *arg) { for(int i0; i20; i) { if(ticket_sum 0) { sleep(1); // 模拟售票耗时 printf(%u 卖出第%d张票\n, pthread_self(), 20-ticket_sum1); ticket_sum--; } } return NULL; } int main() { pthread_t tids[4]; for(int i0; i4; i) { pthread_create(tids[i], NULL, sell_ticket, NULL); } sleep(20); // 等待所有线程完成 return 0; }运行这个程序时你可能会看到各种奇怪的现象同一张票被多个售票员卖出、票号不连续、甚至卖出超过20张票。这就是典型的竞态条件问题 - 当多个线程同时访问和修改共享资源(ticket_sum)时由于执行顺序的不确定性导致的数据不一致。我曾在实际项目中遇到过类似问题。当时我们开发一个电商秒杀系统在高并发场景下出现了商品超卖的情况。调试过程让我深刻理解了多线程同步的重要性 - 就像现实中的售票窗口需要排队机制一样程序中的共享资源访问也需要同步机制来保证秩序。2. 互斥锁最简单的同步武器互斥锁(Mutex)是最基础的线程同步工具它的工作原理就像厕所的门锁 - 一个人进去后锁门其他人必须等待。在编程中互斥锁只有两种状态锁定(locked)和解锁(unlocked)。让我们用互斥锁改造之前的售票程序#includepthread.h pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER; void *sell_ticket(void *arg) { for(int i0; i20; i) { pthread_mutex_lock(mutex); // 加锁 if(ticket_sum 0) { sleep(1); printf(%u 卖出第%d张票\n, pthread_self(), 20-ticket_sum1); ticket_sum--; } pthread_mutex_unlock(mutex); // 解锁 } return NULL; }这里有几个关键点需要注意互斥锁需要在全局范围初始化加锁和解锁必须成对出现临界区(加锁和解锁之间的代码)应该尽可能短我在实际使用中发现不当的加锁方式会导致性能问题甚至死锁。比如忘记解锁会导致其他线程永久等待嵌套加锁可能导致死锁过大的临界区会降低并发性能互斥锁适合保护简单的共享资源访问但它有个明显缺点同一时刻只允许一个线程访问资源即使只是读取操作。这在读多写少的场景下会造成不必要的性能损耗。3. 信号量更灵活的同步控制信号量(Semaphore)是Dijkstra提出的一种更通用的同步机制。不同于互斥锁的二元状态信号量是一个计数器可以更灵活地控制资源访问。信号量有两种主要类型二进制信号量(值0或1)功能类似互斥锁计数信号量(值≥0)控制有限资源的并发访问让我们用二进制信号量实现售票同步#includesemaphore.h sem_t sem; sem_init(sem, 0, 1); // 初始值为1 void *sell_ticket(void *arg) { for(int i0; i20; i) { sem_wait(sem); // P操作(减1) if(ticket_sum 0) { sleep(1); printf(%u 卖出第%d张票\n, pthread_self(), 20-ticket_sum1); ticket_sum--; } sem_post(sem); // V操作(加1) } return NULL; }计数信号量更适合控制有限资源的并发访问。比如限制数据库连接池的最大连接数sem_t db_sem; sem_init(db_sem, 0, 10); // 允许10个并发连接 void *query_db(void *arg) { sem_wait(db_sem); // 获取连接 // 执行数据库操作 sem_post(db_sem); // 释放连接 return NULL; }信号量的优势在于它可以跨进程使用(设置pshared参数为1)并且可以初始化为任意正值。但使用起来也比互斥锁更复杂需要特别注意确保每次wait都有对应的post避免死锁情况正确初始化计数值4. 条件变量等待特定条件的发生条件变量(Condition Variable)用于线程间的条件等待和通知机制。它总是与互斥锁配合使用解决了忙等待的效率问题。考虑一个生产者-消费者场景生产者线程生成数据消费者线程处理数据。当没有数据时消费者应该等待而不是不断轮询。pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER; pthread_cond_t cond PTHREAD_COND_INITIALIZER; int data_ready 0; // 生产者线程 void *producer(void *arg) { while(1) { pthread_mutex_lock(mutex); // 生产数据 data_ready 1; pthread_cond_signal(cond); // 通知消费者 pthread_mutex_unlock(mutex); } } // 消费者线程 void *consumer(void *arg) { while(1) { pthread_mutex_lock(mutex); while(!data_ready) { pthread_cond_wait(cond, mutex); // 自动释放锁并等待 } // 处理数据 data_ready 0; pthread_mutex_unlock(mutex); } }条件变量的使用有几个关键点总是与互斥锁配合使用等待前必须先获取锁使用while循环检查条件(避免虚假唤醒)pthread_cond_wait会原子性地释放锁并进入等待我在开发消息队列时曾大量使用条件变量。它特别适合这种场景线程需要等待某个条件成立才能继续执行而不必忙等待消耗CPU资源。5. 读写锁读多写少的优化方案读写锁(Read-Write Lock)是对互斥锁的优化它区分了读操作和写操作多个读操作可以并发执行写操作需要独占访问读和写操作互斥这种特性非常适合读多写少的场景比如配置管理pthread_rwlock_t rwlock PTHREAD_RWLOCK_INITIALIZER; Config config; // 读线程(多个可并发) void *read_config(void *arg) { pthread_rwlock_rdlock(rwlock); // 读取配置 pthread_rwlock_unlock(rwlock); } // 写线程(独占访问) void *write_config(void *arg) { pthread_rwlock_wrlock(rwlock); // 修改配置 pthread_rwlock_unlock(rwlock); }读写锁的实现通常优先考虑读操作这可能导致写操作饥饿(长时间等待)。某些实现提供了公平策略的读写锁来解决这个问题。在实际项目中我使用读写锁优化过一个缓存系统将读取性能提升了3倍。但需要注意不要长时间持有读锁会影响写操作升级锁时要小心(从读锁升级到写锁可能死锁)考虑使用带超时的版本避免长时间阻塞6. 四种武器的对比与选型经过上面的详细讲解我们来总结一下四种同步机制的特点和适用场景机制特点适用场景性能考虑互斥锁简单、严格互斥简单的共享资源保护临界区要尽可能短信号量计数器、灵活控制并发数资源池、生产者消费者适合跨进程同步条件变量条件等待、避免忙等待事件驱动、任务队列注意虚假唤醒问题读写锁读共享、写独占读多写少的配置、缓存系统注意写操作饥饿问题选择同步机制时我通常考虑以下因素访问模式是纯互斥、读多写少还是条件等待性能需求是否需要最大化并发性能复杂度能否正确实现同步逻辑可维护性代码是否清晰易懂在开发过程中我建议先用最简单的互斥锁实现功能再根据性能测试结果决定是否需要更复杂的同步机制。过早优化往往会导致代码复杂度和bug增加。