各类资料学习下载合集
链接:https://pan.quark.cn/s/7c8c391011eb
在多线程编程的世界里,同步机制是保证数据一致性的基石。我们熟知互斥锁(Mutex)、条件变量(Condition Variable),但还有一位“低调的强者”——信号量(Semaphore)。
很多初学者容易被名字误导,以为信号量和“信号(Signal)”有什么亲戚关系。今天我们就依据一份详实的课堂笔记,来彻底搞懂信号量,并手写一个经典的生产者-消费者模型。
01. 核心概念:张三与张三丰
首先,我们需要通过一个经典的段子来厘清概念:
信号量 (Semaphore) 与 信号 (Signal) 的关系,就像“张三”和“张三丰”的关系——名字虽然像,但二者完全无关。
- 信号 (Signal):是进程间通信机制,比如
kill -9发送的信号。 - 信号量 (Semaphore):是多线程/多进程的同步机制。
信号量的本质
你可以把信号量想象成一个计数器,或者一个初始值为 N 的互斥量。
- 当 N = 1 时:它就是一个互斥锁,一次只允许一个线程访问。
- 当 N > 1 时:它允许 N 个线程同时访问共享资源。这极大地提高了并发性,不需要像互斥锁那样锁住整个对象,而是允许对数据的部分进行共享。
它的底层是一个结构体sem_t,但在使用逻辑上,你可以把它看作一个整数。
02. 关键 API 速查
信号量的函数都在<semaphore.h>头文件中,编译时需要链接线程库-pthread。所有函数成功返回 0,失败返回 -1 并设置 errno。
初始化:
intsem_init(sem_t*sem,intpshared,unsignedintvalue);pshared:0 表示线程间共享(最常用),非 0 表示进程间共享(需配合共享内存)。value:信号量的初始值 N(允许多少线程并发)。
销毁:
intsem_destroy(sem_t*sem);P操作(申请/减减):
intsem_wait(sem_t*sem);// 值 > 0 则减1并返回;值 = 0 则阻塞等待V操作(释放/加加):
intsem_post(sem_t*sem);// 值加1,并唤醒阻塞在等待该信号量的线程超时等待:
intsem_timedwait(sem_t*sem,conststructtimespec*abs_timeout);- 注意:这里的
abs_timeout是绝对时间(1970年1月1日至今的时间),而不是相对时间(比如“再等3秒”)。这点非常容易踩坑!
- 注意:这里的
03. 实战案例:基于信号量的生产者-消费者模型
单纯讲函数太枯燥,我们直接上代码。生产者-消费者模型是信号量最典型的应用场景。
场景设计
我们构建一个固定大小的仓库(环形队列/数组),利用两个信号量来实现同步:
sem_blank:代表空闲格子的数量。初始值为仓库大小(例如 5)。