欢迎光临
我们一直在努力

对于Linux:POSIX信号量以及封装信号量的解析

开篇介绍:

hello 大家,那么其实是和之前学习的system 5 信号量一样,但是在这里,我们将更加详细的进行理解和解析,因为这个是会更重要的,所以,我们直接开始。

很多初学者对信号量的理解停留在“一个计数器”,但只知道这个远远不够。所以本文将会对信号量展开更加详细更加全面的解析。

在开始之前,先明确咱们的学习边界:只聚焦线程间的POSIX信号量(不涉及进程间共享的命名信号量,避免超纲),核心围绕“是什么、怎么用、用在哪、和其他工具的区别”这四个问题展开。话不多说,咱们正式开始。

一、信号量的本质:不是“锁”,是“资源预定器”

要理解信号量,先抛开所有技术术语,从生活场景入手。咱们先想两个常见的场景:

  • 场景1:电影院买票。某场电影有10个座位,每个座位是一个“可用资源”。观众买票就是“申请资源”,买成功后座位归自己,其他人不能再要;看完电影离开(退票)就是“释放资源”,座位重新可用。

  • 场景2:停车场停车。停车场有3个车位,车辆进入是“申请车位资源”,停稳后车位被占用;车辆离开是“释放车位资源”,车位重新空闲。如果3个车位都满了,新来的车只能在入口排队等待。

这两个场景里,有一个核心角色:“剩余可用资源的统计者”。电影院的售票系统要统计剩余座位数,停车场的入口管理员要统计剩余车位数——这个“统计者”,就是信号量的核心原型。

1.1 信号量的核心定义:整数计数器的本质

信号量的本质,就是一个用于统计“剩余可用资源数量”的整数计数器。这个计数器有两个核心特点:

  • 计数器的值 ≥ 0:代表当前剩余的可用资源数量(比如电影院剩余2个座位,计数器就是2;停车场没有空位,计数器就是0)。

  • 对计数器的操作是“原子性”的:不管多少个线程同时操作这个计数器,都不会出现“计数混乱”的情况(比如两个线程同时申请资源,不会把计数器从2直接减到0,而是先减1到1,再减1到0)。

  • 这里要特别纠正一个常见误区:很多人把信号量和“锁”画等号,但其实信号量的功能比锁更强大。锁(比如mutex)只能实现“互斥”(同一时间只有一个线程访问资源),而信号量既能实现互斥,还能实现“同步”(多个线程按资源数量有序访问)。

    1.2 信号量的核心逻辑:申请与释放(P/V操作)

    所有信号量的操作,都围绕两个核心动作展开——这两个动作还有个洋气的名字,来自荷兰语(信号量的发明者是荷兰科学家Dijkstra):

    • P操作:对应荷兰语“Proberen”(发音近似“普洛贝伦”),意思是“尝试”“探测”。核心是“申请资源”:线程想使用某个资源,先尝试获取信号量。

    • V操作:对应荷兰语“Verhogen”(发音近似“费尔霍亨”),意思是“增加”“提升”。核心是“释放资源”:线程用完资源后,把资源归还给系统,更新信号量计数。

    咱们用“电影院买票”的场景,把P/V操作的逻辑讲清楚:

    1.2.1 P操作(申请资源:买票)

    假设电影院剩余座位数(信号量计数器)是2:

  • 观众A来买票(线程A执行P操作):检查计数器(2>0,有剩余座位)→ 计数器减1(变成1)→ 买票成功,观众A获得座位。

  • 观众B来买票(线程B执行P操作):检查计数器(1>0)→ 计数器减1(变成0)→ 买票成功,观众B获得座位。

  • 观众C来买票(线程C执行P操作):检查计数器(0,没有剩余座位)→ 观众C不能买票,只能在售票口排队等待(本质上就是在信号量的等待队列进行等待)→ 线程C阻塞(暂停执行)。

  • 核心结论:P操作的逻辑是“先检查,再减1;有资源就用,没资源就等”。

    1.2.2 V操作(释放资源:退票)

    接着上面的场景,观众B突然有事,决定退票(线程B执行V操作):

  • 观众B退票→ 计数器加1(从0变成1)→ 剩余座位数更新为1。

  • 检查售票口是否有排队的人(信号量的等待队列是否有阻塞线程)→ 发现观众C在排队→ 唤醒观众C,让他重新执行P操作。

  • 观众C被唤醒后,再次执行P操作:检查计数器(1>0)→ 计数器减1(变成0)→ 买票成功。

  • 如果没有观众排队(等待队列为空),V操作就只做一件事:计数器加1。

    核心结论:V操作的逻辑是“先加1,再检查;有线程排队就唤醒,没排队就结束”。

    1.2.3 关键提醒:P/V操作必须成对出现

    就像“买票”和“退票”要成对一样,线程执行P操作(申请资源)后,必须执行V操作(释放资源)。如果只P不V,会导致计数器一直为0,其他线程永远阻塞(比如观众买了票不进场也不退票,座位一直被占用,其他人永远买不到);如果只V不P,会导致计数器超过“最大资源数”(比如没买票就退票,电影院的座位数会统计错误)。

    二、POSIX信号量核心函数接口详解

    理解了信号量的本质和P/V操作,接下来咱们看POSIX标准提供的核心函数接口。这些接口是实现信号量功能的工具,记住:所有接口的返回值规则一致——成功返回0,失败返回-1(注意:不是返回错误码,这和mutex、条件变量的接口有区别,一定要记牢)。

    使用这些函数前,必须包含头文件:#include <semaphore.h>,semaphore即是信号量的英文

    2.1 信号量初始化:sem_init

    要使用信号量,首先得创建并初始化它——就像咱们要售票,得先有“售票系统”并设置好“初始座位数”。

    2.1.1 函数原型

    int sem_init(sem_t *sem, int pshared, unsigned int value);

    2.1.2 参数详解

    • 第一个参数:sem_t *sem——信号量变量的地址。咱们需要先定义一个sem_t类型的变量(比如sem_t mutex;),然后把它的地址传给这个参数,函数会初始化这个变量。

    • 第二个参数:int pshared——信号量的共享范围。 pshared = 0:表示信号量用于“线程间共享”(这是咱们最常用的场景,比如同一个进程里的多个线程共享一个资源)。

    • pshared ≠ 0:表示信号量用于“进程间共享”(比如两个不同的进程共享一个文件资源)。咱们这篇文章不涉及进程间共享,所以直接传0即可。

    第三个参数:unsigned int value——信号量的初始值。这个值就是“最大可用资源数”(比如电影院有10个座位,初始值就设为10;停车场有3个车位,初始值就设为3)。

    2.1.3 示例代码(初始化一个互斥信号量)

    sem_t sem;
    // 初始化:线程间共享,初始值为1(表示只有1个可用资源,即互斥锁)
    if (sem_init(&sem, 0, 1) == -1) {
    perror("sem_init failed"); // 出错时打印错误信息
    exit(1);
    }

    2.1.4 常见问题

    Q:初始值可以设为0吗?

    A:可以。这表示“初始状态下没有可用资源”,所有执行P操作的线程都会阻塞,直到有线程执行V操作释放资源(比如电影院还没开业,没有座位可用,观众只能排队,直到工作人员开放售票)。

    2.2 信号量销毁:sem_destroy

    信号量不用的时候,必须销毁——就像电影院关门后,要销毁售票系统,释放占用的资源。如果不销毁,会导致资源泄露。

    2.2.1 函数原型

    int sem_destroy(sem_t *sem);

    2.2.2 参数与返回值

    • 参数:sem_t *sem——要销毁的信号量变量地址(和sem_init的第一个参数一致)。

    • 返回值:成功返回0,失败返回-1(比如信号量未初始化,或还有线程在等待这个信号量,销毁会失败)。

    2.2.3 示例代码

    if (sem_destroy(&mutex) == -1) {
    perror("sem_destroy failed");
    exit(1);
    }

    2.3 P操作实现:sem_wait(核心!申请资源)

    sem_wait函数是P操作的具体实现——“申请资源,没资源就阻塞等待”。这是信号量最常用的函数之一,必须熟练掌握。

    2.3.1 函数原型

    int sem_wait(sem_t *sem);

    2.3.2 核心逻辑(原子性操作)

    函数内部会原子性地执行以下步骤(原子性意味着这些步骤要么全部完成,要么全部不完成,不会被其他线程打断):

  • 检查信号量计数器的值是否 > 0(是否有可用资源)。

  • 如果是:计数器的值减1(资源申请成功),函数返回0。

  • 如果否:当前线程进入信号量的“等待队列”,阻塞暂停执行(直到被其他线程的sem_post函数唤醒)。

  • 被唤醒后,线程会重新执行步骤1-2(相当于“重新申请资源”)。

  • 2.3.3 生活示例对应

    sem_wait就像“观众去电影院买票”:

    • 有剩余座位(计数器>0):买票成功(计数器减1),进场观影。

    • 没有剩余座位(计数器=0):在售票口排队(线程阻塞),直到有人退票(其他线程执行sem_post)。

    2.3.4 常见问题

    Q:sem_wait会被信号中断吗?

    A:会。如果线程在sem_wait阻塞时,收到一个信号(比如Ctrl+C),sem_wait会返回-1,并且设置错误码为EINTR。实际开发中,可以用循环来处理这种情况:

    // 处理信号中断的sem_wait
    while (sem_wait(&mutex) == -1) {
    if (errno != EINTR) { // 只有不是信号中断的错误,才退出
    perror("sem_wait failed");
    exit(1);
    }
    }

    2.4 V操作实现:sem_post(核心!释放资源)

    sem_post函数是V操作的具体实现——“释放资源,唤醒等待的线程”。和sem_wait成对出现,缺一不可。

    2.4.1 函数原型

    int sem_post(sem_t *sem);

    2.4.2 核心逻辑(原子性操作)

    函数内部会原子性地执行以下步骤:

  • 将信号量计数器的值加1(释放资源,剩余可用资源数增加)。

  • 检查信号量的“等待队列”是否有线程在阻塞。

  • 如果有:随机唤醒一个线程(不同系统可能是按排队顺序,不用深究,知道会唤醒一个即可),让它重新执行sem_wait(申请资源)。

  • 如果没有:函数直接返回0,什么都不做。

  • 2.4.3 生活示例对应

    sem_post就像“观众退票”:

    • 没有观众排队:退票后,剩余座位数增加(计数器加1),结束。

    • 有观众排队:退票后,剩余座位数增加,同时喊排在最前面的观众来买票(唤醒一个阻塞线程)。

    2.4.4 常见错误

    错误场景:没有执行sem_wait,直接执行sem_post(没买票就退票)。

    后果:信号量计数器会不断增加,超过“最大可用资源数”(比如电影院只有10个座位,计数器会变成11、12…),导致资源统计错误。此时sem_post会返回-1,错误码为EOVERFLOW。

    2.5 辅助函数:sem_getvalue(获取信号量当前值)

    这个函数不是核心操作,但很实用——可以获取信号量当前的计数器值(比如查看电影院剩余座位数、停车场剩余车位数)。

    2.5.1 函数原型

    int sem_getvalue(sem_t *sem, int *sval);

    2.5.2 参数与逻辑

    • 参数1:sem_t *sem——信号量变量地址。

    • 参数2:int *sval——用于存储信号量当前值的指针。函数会把计数器的当前值写入这个指针指向的变量。

    • 逻辑:如果信号量当前有线程在等待(计数器=0),不同系统的行为可能不同(有些返回0,有些返回-等待线程数),但咱们只需要知道“正常情况下,它会返回当前剩余可用资源数”即可。

    2.5.3 封装辅助函数(方便打印)

    为了方便在代码中打印信号量的值,咱们可以封装一个简单的辅助函数:

    int get_sem_value(sem_t *sem) {
    int val;
    if (sem_getvalue(sem, &val) == -1) {
    perror("获取信号量值失败");
    return -1;
    }
    return val;
    }

    三、实战案例:从代码看信号量的应用

    理论讲完了,咱们用两个实战案例把知识点落地。这两个案例覆盖了信号量的两大核心场景:互斥(二元信号量)和同步(计数信号量)。

    案例1:二元信号量——模拟抢票(实现互斥锁功能)

    场景:有5张电影票,2个线程同时抢票。要求同一时间只有一个线程能操作“剩余票数”(避免超卖)。

    核心思路:用信号量实现互斥——把信号量初始值设为1(表示只有1个“操作票数”的资源),线程抢票前执行sem_wait(申请操作权),抢票后执行sem_post(释放操作权)。这种初始值为1的信号量,叫做“二元信号量”,功能和mutex锁完全一致。

    3.1.1 完整代码

    #include <iostream>
    #include <pthread.h>
    #include <unistd.h>
    #include <semaphore.h>
    #include <errno.h>

    // 1. 定义信号量(互斥用,初始值1)和共享资源
    sem_t mutex; // 二元信号量:相当于mutex锁
    int ticket_count = 5; // 共享资源:剩余票数

    // 2. 线程函数:模拟抢票
    void *buy_ticket(void *arg) {
    int id = *(int*)arg; // 获取线程ID(区分两个抢票线程)

    while (1) {
    // P操作:申请信号量(相当于上锁,获取操作票数的权限)
    // 处理信号中断的情况
    while (sem_wait(&mutex) == -1) {
    if (errno != EINTR) {
    perror("sem_wait failed");
    pthread_exit(NULL);
    }
    }

    // 临界区:访问共享资源(修改ticket_count)
    // 临界区的代码,同一时间只有一个线程能执行
    if (ticket_count > 0) {
    printf("线程%d:抢到第%d张票\\n", id, ticket_count);
    ticket_count–;
    sleep(1); // 模拟打印票据、记录信息的耗时操作
    } else {
    // 票抢完了,先释放信号量再退出(避免死锁)
    sem_post(&mutex);
    break; // 退出循环,线程结束
    }

    // V操作:归还信号量(相当于解锁,释放操作票数的权限)
    sem_post(&mutex);

    sleep(1); // 模拟线程切换(让另一个线程有机会抢票)
    }

    return NULL;
    }

    int main() {
    // 3. 初始化信号量:线程共享,初始值1(二元信号量,互斥锁)
    if (sem_init(&mutex, 0, 1) == -1) {
    perror("sem_init failed");
    return 1;
    }

    // 4. 创建两个抢票线程
    pthread_t t1, t2;
    int id1 = 1, id2 = 2;
    // 传递线程ID时,要传变量的地址(注意:不能传临时变量)
    if (pthread_create(&t1, NULL, buy_ticket, &id1) != 0) {
    perror("pthread_create t1 failed");
    return 1;
    }
    if (pthread_create(&t2, NULL, buy_ticket, &id2) != 0) {
    perror("pthread_create t2 failed");
    return 1;
    }

    // 5. 等待两个线程结束(主线程阻塞,直到子线程完成)
    if (pthread_join(t1, NULL) != 0) {
    perror("pthread_join t1 failed");
    return 1;
    }
    if (pthread_join(t2, NULL) != 0) {
    perror("pthread_join t2 failed");
    return 1;
    }

    // 6. 销毁信号量(释放资源)
    if (sem_destroy(&mutex) == -1) {
    perror("sem_destroy failed");
    return 1;
    }

    printf("所有票已抢完!\\n");
    return 0;
    }

    3.1.2 代码逐行解析

  • 定义信号量和共享资源: sem_t mutex;:定义二元信号量(用于互斥)。

  • int ticket_count = 5;:共享资源(剩余票数),两个线程都会操作它,所以需要互斥保护。

  • 线程函数buy_ticket: 获取线程ID:int id = *(int*)arg;,用于区分两个抢票线程。

  • sem_wait操作:申请信号量(上锁),处理信号中断的情况(避免被信号打断后程序异常)。

  • 临界区:if (ticket_count > 0) 到 else 之间的代码,同一时间只有一个线程能执行(因为信号量初始值为1,只有一个线程能申请成功)。

  • else分支:票抢完了,必须先执行sem_post(释放信号量)再break,否则信号量会一直为0,另一个线程永远阻塞(死锁)。

  • sem_post操作:释放信号量(解锁),让另一个线程有机会申请资源。

  • sleep(1):模拟线程切换,让两个线程能交替抢票(如果没有这行,可能一个线程抢完所有票)。

  • main函数: sem_init:初始化信号量,线程间共享,初始值1(二元信号量)。

  • pthread_create:创建两个线程,传递线程ID(注意:不能传递临时变量的地址,比如&i,因为i是循环变量,会被修改)。

  • pthread_join:主线程等待子线程结束,避免主线程提前退出,子线程还没执行完。

  • sem_destroy:销毁信号量,释放资源。

  • 3.1.3 运行结果预测

    线程1:抢到第5张票
    线程2:抢到第4张票
    线程1:抢到第3张票
    线程2:抢到第2张票
    线程1:抢到第1张票
    所有票已抢完!

    (注:线程1和线程2的执行顺序可能略有不同,比如线程2先抢到第5张票,但最终会抢完5张票,不会出现超卖的情况)

    3.1.4 核心结论:二元信号量 = 互斥锁

    这个案例完美证明了:初始值为1的二元信号量,功能和mutex锁完全一致:

    • sem_wait ≈ pthread_mutex_lock(上锁):同一时间只有一个线程能进入临界区。

    • sem_post ≈ pthread_mutex_unlock(解锁):释放临界区的访问权,让其他线程进入。

    那为什么要有两种工具?因为信号量的功能更强大(可以实现同步),而mutex锁只专注于互斥。

    案例2:计数信号量——模拟停车场(实现同步功能)

    场景:停车场有3个车位(最大可用资源数3),5辆车(5个线程)依次到达。车辆进入停车场前要申请车位(sem_wait),离开时释放车位(sem_post)。如果车位满了,新来的车只能排队等待。

    核心思路:用计数信号量(初始值3)管理车位资源,实现多个线程的同步——线程按资源数量有序访问,最多3个线程同时占用资源(停车)。

    3.2.1 完整代码

    #include <iostream>
    #include <pthread.h>
    #include <unistd.h>
    #include <semaphore.h>
    #include <errno.h>

    // 1. 定义信号量(初始值=3,代表3个停车位)和共享变量
    sem_t parking_sem; // 计数信号量:管理停车位资源
    int car_id = 0; // 车辆ID(用于标识不同车辆,原子操作修改)

    // 辅助函数:获取信号量当前值(方便打印剩余车位)
    int get_sem_value(sem_t *sem) {
    int val;
    if (sem_getvalue(sem, &val) == -1) {
    perror("获取信号量值失败");
    return -1;
    }
    return val;
    }

    // 2. 线程函数:模拟车辆停车+离开
    void *car_behavior(void *arg) {
    // 分配车辆ID(用原子操作,避免多个线程同时修改car_id导致混乱)
    int id;
    // 这里用简单的互斥方式(也可以用atomic_int,不过咱们用信号量的知识)
    static sem_t id_sem;
    static int init_flag = 0;
    if (!init_flag) {
    sem_init(&id_sem, 0, 1);
    init_flag = 1;
    }
    sem_wait(&id_sem);
    id = ++car_id;
    sem_post(&id_sem);

    printf("车辆%d:到达停车场\\n", id);

    // P操作:申请停车位(信号量–,剩余车位减少)
    while (sem_wait(&parking_sem) == -1) {
    if (errno != EINTR) {
    perror("sem_wait failed");
    pthread_exit(NULL);
    }
    }
    printf("车辆%d:成功停车(剩余车位:%d)\\n", id, get_sem_value(&parking_sem));

    sleep(3); // 模拟停车时长(比如停车3秒)

    // V操作:离开停车场(信号量++,剩余车位增加)
    if (sem_post(&parking_sem) == -1) {
    perror("sem_post failed");
    pthread_exit(NULL);
    }
    printf("车辆%d:离开停车场(剩余车位:%d)\\n", id, get_sem_value(&parking_sem));

    return NULL;
    }

    int main() {
    // 3. 初始化信号量:线程共享,初始值=3(3个停车位)
    if (sem_init(&parking_sem, 0, 3) == -1) {
    perror("sem_init failed");
    return 1;
    }

    // 4. 创建5辆车的线程(超过停车位数量,模拟排队)
    pthread_t cars[5];
    for (int i = 0; i < 5; i++) {
    if (pthread_create(&cars[i], NULL, car_behavior, NULL) != 0) {
    perror("pthread_create failed");
    return 1;
    }
    sleep(1); // 让车辆分批到达(每隔1秒来一辆车)
    }

    // 5. 等待所有车辆线程结束
    for (int i = 0; i < 5; i++) {
    if (pthread_join(cars[i], NULL) != 0) {
    perror("pthread_join failed");
    return 1;
    }
    }

    // 6. 销毁信号量
    if (sem_destroy(&parking_sem) == -1) {
    perror("sem_destroy failed");
    return 1;
    }

    printf("停车场关闭!\\n");
    return 0;
    }

    3.2.2 代码逐行解析

  • 定义信号量和共享变量: sem_t parking_sem;:计数信号量,初始值3(3个停车位)。

  • int car_id = 0;:车辆ID,多个线程会同时修改它,所以需要用信号量(id_sem)实现互斥修改(避免两个线程拿到同一个ID)。

  • 辅助函数get_sem_value:获取信号量当前值,用于打印剩余车位。

  • 线程函数car_behavior: 分配车辆ID:用静态信号量id_sem(初始值1)实现互斥,确保每个线程拿到唯一的ID(避免多个线程同时执行id = ++car_id导致ID重复)。

  • 车辆到达:打印“车辆X:到达停车场”。

  • sem_wait操作:申请停车位。如果有剩余车位(信号量>0),申请成功,信号量减1;如果没有剩余车位(信号量=0),线程阻塞等待。

  • 停车耗时:sleep(3)模拟车辆停车3秒(这段时间内,车位被占用)。

  • sem_post操作:释放停车位,信号量加1,同时唤醒一个等待的线程(如果有车辆在排队)。

  • main函数: sem_init:初始化计数信号量,初始值3(3个停车位)。

  • 创建5个线程:模拟5辆车,sleep(1)让车辆分批到达(每隔1秒来一辆,更符合实际场景)。

  • pthread_join:等待所有车辆离开(线程结束)。

  • sem_destroy:销毁信号量。

  • 3.2.3 运行结果预测

    车辆1:到达停车场
    车辆1:成功停车(剩余车位:2)
    车辆2:到达停车场
    车辆2:成功停车(剩余车位:1)
    车辆3:到达停车场
    车辆3:成功停车(剩余车位:0)
    车辆4:到达停车场
    车辆5:到达停车场
    车辆1:离开停车场(剩余车位:1)
    车辆4:成功停车(剩余车位:0)
    车辆2:离开停车场(剩余车位:1)
    车辆5:成功停车(剩余车位:0)
    车辆3:离开停车场(剩余车位:1)
    车辆4:离开停车场(剩余车位:2)
    车辆5:离开停车场(剩余车位:3)
    停车场关闭!

    结果分析:

    • 车辆1、2、3依次到达,成功停车(剩余车位从3减到0)。

    • 车辆4、5到达时,车位已满(信号量=0),只能排队等待。

    • 车辆1停车3秒后离开,释放车位(信号量从0变1),唤醒等待的车辆4,车辆4成功停车。

    • 后续车辆依次离开、停车,直到所有车辆处理完毕,停车场关闭。

    3.2.4 核心结论:计数信号量实现同步

    这个案例体现了计数信号量的核心价值——同步多个线程,控制同时访问资源的线程数量:

    • 信号量初始值N:最多有N个线程同时占用资源。

    • 线程申请资源(sem_wait):如果资源未满,直接占用;如果资源已满,阻塞等待。

    • 线程释放资源(sem_post):唤醒一个等待的线程,让它占用资源。

    这种场景用mutex锁无法实现(mutex锁只能让1个线程访问资源),这就是信号量比mutex锁更强大的地方。

    四、关键扩展:信号量与其他同步工具的对比

    学到这里,你可能会有疑问:信号量、互斥锁(mutex)、条件变量,这三个工具都能实现线程同步/互斥,它们的区别是什么?该怎么选?

    咱们先明确核心定位,再逐一对比。

    4.1 三者核心定位

    • 互斥锁(mutex):专注于互斥——同一时间只有一个线程访问临界区,解决“多个线程竞争资源”的问题。

    • 信号量:兼顾互斥与同步——既能像mutex一样实现互斥(二元信号量),也能像计数工具一样实现同步(计数信号量),自带资源计数功能。

    • 条件变量:专注于通知——不管理资源,也不计数,只负责“通知等待的线程:某个条件已经满足,而这个条件需要我们自己设定,不像信号量可以自己计数,那么它记的数就是它的条件!!!”,必须搭配mutex锁使用。

    4.2 信号量 vs 互斥锁(mutex)

    对比维度

    信号量

    互斥锁(mutex)

    核心功能

    互斥(二元信号量)+ 同步(计数信号量)

    仅互斥

    资源计数

    自带计数器,可统计剩余可用资源数

    无计数功能,仅标识“资源是否被占用”

    适用场景

    1. 控制同时访问资源的线程数量(计数信号量);2. 简单互斥场景(二元信号量)。

    仅用于互斥场景(同一时间一个线程访问临界区)。

    操作灵活性

    可以在一个线程中P操作,另一个线程中V操作(比如线程A申请资源,线程B释放资源)。

    必须在同一个线程中上锁(pthread_mutex_lock)和解锁(pthread_mutex_unlock)(不能跨线程解锁)。

    选择建议

    需要控制资源数量(同步)时,优先选信号量。

    仅需要互斥时,优先选mutex(接口更简单,语义更清晰)。

    4.3 信号量 vs 条件变量

    这是最容易混淆的一组,咱们从6个核心维度详细对比,结合生活例子理解。

    4.3.1 本质定位差异

    • 信号量:带计数器的资源管理器——直接统计“剩余可用资源数”,知道“有多少资源可以用”。

    • 条件变量:纯通知器——不知道“有多少资源”,只知道“某个条件是否满足”(比如“停车场有空位了”),不管理资源。

    4.3.2 核心功能差异

    用“停车场管理”的场景,直观对比两者功能:

    • 信号量场景:停车场管理员手里有一个“剩余车位计数器”(信号量)。车辆到达时,管理员直接看计数器(有车位就放行,没车位就让排队);车辆离开时,管理员更新计数器,同时喊排队的第一辆车进来。整个过程,管理员(信号量)既管“计数”又管“放行/排队”。

    • 条件变量场景:停车场没有计数器,管理员(条件变量)只负责“传话”。车辆到达时,得自己问“有没有空位”(搭配互斥锁检查资源);如果没有空位,就告诉管理员“我等空位,有消息叫我”(条件变量等待);其他车辆离开时,告诉管理员“有空位了”(条件变量通知),管理员再喊一个等待的车辆进来。这里,条件变量只做“通知”,不管“计数”和“资源检查”。

    4.3.3 依赖关系差异

    • 信号量:独立工作——自带资源计数和等待队列,不需要搭配其他工具就能完成“申请-等待-释放-唤醒”的完整流程(比如前面的抢票、停车场案例,仅用信号量就实现了核心逻辑)。

    • 条件变量:必须依赖互斥锁——自身没有资源管理能力,也没有同步机制,必须和互斥锁配合使用。原因有两个:一是条件变量的“等待”和“通知”操作不是原子的,需要互斥锁保护,避免出现“虚假唤醒”(比如线程刚要进入等待,就收到了通知,导致永远等待);二是条件变量需要通过互斥锁访问共享资源(比如检查“剩余车位”这个共享变量)。

    4.3.4 等待与唤醒逻辑差异

    • 信号量:等待队列是“隐式”的,由系统自动管理。线程调用sem_wait时,若资源不足会自动进入等待队列;其他线程调用sem_post时,系统会自动唤醒队列中的一个线程,无需额外操作。

    • 条件变量:等待队列是“显式”的,需要手动关联。线程需要调用pthread_cond_wait(搭配互斥锁)进入等待队列;唤醒时,需要手动调用pthread_cond_signal(唤醒一个)或pthread_cond_broadcast(唤醒所有)。而且,条件变量可能出现“虚假唤醒”——即使没有线程调用通知,所以等待函数的调用得是使用while循环,等待的线程也可能被唤醒(系统层面的异常),所以必须在循环中检查条件是否满足(比如“有没有空位”)。

    4.3.5 适用场景差异

    • 信号量适用场景: 1. 明确知道“资源数量”的场景(比如3个车位、5张票); 2. 需要控制“同时访问资源的线程数量”的同步场景(比如限制5个线程同时读取文件); 3. 简单的互斥场景(二元信号量)。

    • 条件变量适用场景: 1. 不知道具体资源数量,但知道“条件满足与否”的场景(比如“队列不为空”“缓冲区有数据”); 2. 需要“批量唤醒”线程的场景(比如用pthread_cond_broadcast唤醒所有等待“缓冲区有数据”的线程); 3. 复杂的同步逻辑(比如生产者-消费者模型中,生产者唤醒消费者,消费者唤醒生产者)。

    4.3.6 代码实现复杂度差异

    以“停车场管理”为例,对比两者的代码复杂度:

    1. 信号量实现:只需初始化信号量(初始值3),线程执行sem_wait(申请车位)和sem_post(释放车位),代码简洁(参考案例2)。

    2. 条件变量实现:需要定义互斥锁(保护剩余车位变量)和条件变量,线程流程为: – 申请互斥锁 → 检查是否有车位 → 有车位则占用(修改剩余车位)→ 释放互斥锁; – 没有车位则调用pthread_cond_wait(释放互斥锁并等待)→ 被唤醒后重新申请互斥锁,再次检查条件; – 车辆离开时:申请互斥锁 → 修改剩余车位 → 调用pthread_cond_signal唤醒等待线程 → 释放互斥锁。 代码量更多,且需要处理互斥锁的获取/释放和条件的循环检查,容易出错。

    4.3.7 核心对比总结表

    对比维度

    信号量

    条件变量

    本质定位

    带计数的资源管理器

    纯通知器(无计数)

    核心功能

    资源计数、申请等待、释放唤醒(一站式)

    仅负责线程间的条件通知(等待/唤醒)

    依赖工具

    独立工作,无需其他工具

    必须搭配互斥锁使用

    等待队列

    隐式,系统自动管理

    显式,需手动关联等待/唤醒

    虚假唤醒

    不会出现(系统保证唤醒的有效性)

    可能出现,需循环检查条件

    适用场景

    已知资源数量的同步/互斥场景

    基于条件判断的复杂同步场景

    五、POSIX信号量使用注意事项

    掌握了信号量的理论和用法后,还要注意一些实际开发中的“坑”,避免出现程序异常、死锁等问题。

    5.1 必须保证P/V操作成对出现

    这是最基础也最容易出错的点,前面虽然提过,但这里要强调具体场景:

    • 场景1:线程执行P操作后,因异常退出(比如代码崩溃、调用exit),没执行V操作——导致信号量计数器永远停留在“已占用”状态,其他线程永远阻塞(死锁)。 解决办法:在可能退出的分支前,务必执行V操作;或者使用“资源清理函数”(比如pthread_cleanup_push),确保线程退出时能释放信号量。

    • 场景2:重复执行V操作(没执行P操作就V,或执行多次V)——导致信号量计数器超过最大资源数,资源统计混乱(比如电影院10个座位,计数器变成11,导致11个观众进场,出现座位冲突)。 解决办法:严格遵循“一次P对应一次V”的逻辑,在代码中明确标注P/V的对应关系,避免漏写或多写。

    5.2 处理sem_wait的信号中断问题

    如前文所述,sem_wait在阻塞时可能被信号中断(返回-1,错误码EINTR),如果不处理,会导致线程错误退出,无法继续等待资源。

    正确处理方式:用循环包裹sem_wait,只有当错误码不是EINTR时,才认为是真正的错误,退出循环;如果是EINTR,继续等待(重新执行sem_wait)。示例代码参考2.3.4节的处理逻辑,实际开发中建议封装成工具函数(比如safe_sem_wait),避免重复编码。

    5.3 注意信号量的初始化与销毁时机

    • 初始化时机:必须在所有线程创建前初始化信号量——如果线程已经开始执行,信号量还没初始化,会导致线程访问未初始化的信号量(行为未定义,可能崩溃)。

    • 销毁时机:必须在所有线程都不再使用信号量后,再销毁——如果还有线程在等待信号量(sem_wait阻塞中),调用sem_destroy会失败(返回-1,错误码EBUSY),甚至导致程序崩溃。 解决办法:用pthread_join等待所有子线程结束后,再调用sem_destroy;销毁前可以用sem_getvalue检查信号量状态(虽然不同系统行为可能不同,但可作为辅助判断)。

    5.4 避免信号量的“优先级反转”问题

    什么是优先级反转?比如:低优先级线程A执行P操作占用信号量,此时高优先级线程B执行P操作,因资源被占用而阻塞;而低优先级线程A又被中优先级线程C抢占(CPU调度),导致高优先级线程B一直等待低优先级线程A释放资源——原本高优先级应优先执行,结果因信号量占用,优先级被“反转”了。

    解决办法:在支持优先级继承的系统中,可以使用“优先级继承信号量”(比如Linux的PTHREAD_MUTEX_PRIORITY_INHERIT属性,但POSIX信号量本身不直接支持,需结合系统特定接口);或者在关键区域(P操作后到V操作前),暂时提高低优先级线程的优先级,避免被其他线程抢占。

    5.5 不要用信号量实现复杂的条件同步

    信号量适合“基于资源数量”的同步,而不适合“基于复杂条件”的同步(比如“等待队列不为空且缓冲区未满”)。

    比如:生产者-消费者模型中,如果需要同时满足“缓冲区有数据”(消费者等待)和“缓冲区有空位”(生产者等待),用信号量可以实现(两个信号量:empty计数空位,full计数数据),但如果条件更复杂(比如“消费者只取奇数编号的数据”),用信号量会非常繁琐,且容易出错。此时更适合用“条件变量+互斥锁”,直接检查条件是否满足,逻辑更清晰。

    六、总结:POSIX信号量的核心价值与适用场景

    通过前面的本质解析、接口详解、实战案例和对比分析,咱们可以给POSIX信号量一个清晰的定位:

    POSIX信号量是一种兼顾互斥与同步的线程同步工具,核心优势在于“自带资源计数和等待队列”,可以独立完成“资源申请-等待-释放-唤醒”的完整流程,无需依赖其他工具。

    6.1 核心价值

  • 功能灵活:既能用二元信号量实现互斥(替代mutex锁),又能用计数信号量实现同步(控制并发线程数),覆盖大部分线程同步场景。

  • 接口简洁:核心接口只有sem_init、sem_destroy、sem_wait、sem_post四个,容易记忆和使用,适合新手入门。

  • 系统支持好:所有符合POSIX标准的系统(Linux、Unix、macOS等)都支持,兼容性强,适合跨平台开发。

  • 6.2 最佳适用场景

  • 控制同时访问资源的线程数量(比如限制5个线程同时操作数据库连接池、3个线程同时读取文件)——用计数信号量,初始值设为资源数量。

  • 简单的互斥场景(比如两个线程抢票、单个共享变量的修改)——用二元信号量(初始值1),虽然mutex也能实现,但信号量接口更简洁(无需初始化互斥锁属性)。

  • 线程间的“生产-消费”同步(固定资源数量)——比如生产者生产数据放入缓冲区(缓冲区大小固定),消费者取出数据,用两个信号量(empty计数空位,full计数数据)实现,逻辑清晰。

  • 6.3 不适用场景

  • 复杂条件的同步(比如基于多个变量的条件判断)——适合用“条件变量+互斥锁”。

  • 需要优先级继承/优先级天花板的场景——适合用带优先级属性的mutex锁(POSIX信号量本身不支持优先级相关功能)。

  • 进程间共享信号量(本文不涉及,但补充说明)——虽然POSIX信号量支持进程间共享(pshared≠0),但需要放在共享内存中,配置复杂;如果是进程间同步,更推荐用“命名信号量”(sem_open等接口),或其他进程间同步工具(比如管道、消息队列)。

  • 最后,咱们用一句话总结:POSIX信号量是多线程编程中“性价比很高”的同步工具,掌握它的本质(资源预定器)和核心操作(P/V),再结合实战案例理解适用场景,就能轻松应对大部分线程同步问题。

    最后的最后,给大家示例代码——三十年经验,三十秒教给你!!!

    示例代码:

    #include <iostream>
    #include <pthread.h>
    #include <unistd.h>
    #include <semaphore.h>

    //ok,那么在本文件,就来讲一下POSIX信号量,那么其实是和之前学习的system 5 信号量一样
    //那么我们首先必须明确,信号量的本质就是一个整数计数器,是的,就是一个计数器
    //那么这个计数器就是负责计数我们用户所指定的资源剩余的可用的数量(比如数组剩余空间)
    //POSIX 信号量的计数器默认表示 “剩余可用资源数”(不是已占用数)
    //其实也是可以将信号量看做对用户所指定的资源的预定机制,就像我们看电影提前买一个座位
    //然后那个座位就是我们的了,即使我们不去看电影,那个座位也得是我们的
    //不能有其他人去占据我们所买的座位
    //那么把线程看作为用户,而信号量就是统计预定票
    //那么信号量我们是可以看做为一个计数器,这是没问题的
    //当有线程要申请信号量的时候,那么要是信号量没有达到0的话(即剩余可用资源个数还大于0)
    //线程就可以申请信号量成功,本质上是对信号量所对应的资源的一个预定
    //同时信号量会–,因为本质上是计数器嘛,然后多了一个线程去预定(申请信号量)
    //那么信号量肯定就得–,代表这块指定的资源的剩余的资源个数少了一个,即已经被一个线程给预定走了一个
    //但是要是信号量==0或者甚至极端情况下小于0呢?
    //那么哪里也是说没有剩余的资源可以被预定,
    //那么这个时候,信号量就会说,不好意思,没有可以被预定的资源了
    //你(线程)就现在我这里排队吧,等有剩余的资源了,你才可以进行预定
    //其实对应的就是让申请信号量的线程进行阻塞等待,在哪里等待呢?
    //就在这个信号量的等待队列进行等待
    //要是有多个线程同时申请,那么就是都一起进行阻塞等待
    //等有可以被预定的资源了,信号量再从等待队列里随机唤醒一个去预定资源
    //就像买电影票,一共10个座位,那么信号量是2,也就是代表说还有两个座位还可以被预定
    //而其他8个位置已经被预定了,那么当有人去申请信号量了,即去买票预定座位了
    //那么因为还有剩余的位置(信号量>0),所以可以买票预定座位成功
    //但是这也就代表说剩余的可以被预定的座位减少了一个,同时也是指说还有一个位置可以被预定
    //那么谁记录呢?无疑就是信号量,信号量要–,从原本的2–变为1
    //我们把信号量的–操作称为P操作
    //而要是信号量为0,即代表没有剩余的座位了
    //那么申请预定买票的人就只能等着了,而且要在该信号量下进行等待
    //直到信号量大于0了,也就是有可以被预定的资源了,那么信号量就会随机通知一个用户可以买票了
    //那么这也就是说明,用户不必一直去问信号量,信号量自己会进行通知
    //这就像条件变量的等待函数和唤醒函数
    //这个还是很好理解的
    //而要是有人预定了座位然后退款了呢,那么是不是就是代表说剩余的可以被预定的座位多了一个
    //比如从原本的2变为了3,那么此时信号量就得++,从原本的2++变为3
    //而这,就是对应着有线程使用完了资源,然后退出了,并归还信号量
    //那么不要说要是信号量就是满的,即指定资源全部都是可以被预定的
    //然后要归还信号量怎么办,那肯定失败呀,所以这一点要想清楚,一定要结合生活中的例子进行理解
    //而此时有一个问题,要是因为信号量为0了所以有一堆线程在信号量的等待队列进行等待
    //然后这个时候有一个线程归还信号量了,那么,根据上面说的,信号量是会随机唤醒一个线程进行预定资源的
    //所以呀,发生归还信号量的时候,信号量不仅会进行++,
    //还会判断在归还信号量之前,是不是信号量为0,即有线程在信号量的等待队列进行等待
    //如果是的话,那么信号量还会进行随机唤醒一个线程进行预定资源的操作
    //而要是没有的话,那么就是进行简单的++
    //我们把信号量的++操作称为V操作
    //那么申请信号量和归还信号量,都有对应的函数接口调用
    //而且函数所做的不止是上面简单的–和++,还有就是上面说的一系列操作
    //那么接下来我就来详细的介绍一下信号量的各个函数接口

    //首先就是信号量的初始化函数:
    //#include <semaphore.h>,注意要包含头文件
    //int sem_init(sem_t *sem, int pshared, unsigned int value);
    //参数:
    //第一个参数:信号量变量的地址,这个很简单
    //第二个参数:pshared:0表示线程间共享,非零表示进程间共享,在这里我们直接传入0即可
    //第三个参数:value:信号量初始值,其实就是我们给信号量设定的最大值
    //即信号量所对应的资源的最大的可被预定的资源个数
    //返回值就是成功了返回0,失败了返回-1,注意不是返回错误码哦,要和前面学习的锁和条件变量进行区分
    //然后就是信号量的销毁函数,不用了肯定就得销毁
    //int sem_destroy(sem_t *sem);
    //不必多说吧,参数就是传入信号量变量的地址
    //而返回值就是成功了返回0,失败了返回-1,注意不是返回错误码哦,要和前面学习的锁和条件变量进行区分

    //接下来要说的就是信号量的重头函数,首先是P操作的函数,也就是上面所说的申请信号量的操作
    //sem_wait() —— 申请信号量(“买票,没票就排队等”)
    //函数原型:
    //int sem_wait(sem_t *sem);
    //具体操作(原子性,一步到位):
    //检查信号量计数器是否>0(还有票):
    //是:计数器(信号量)-1(买票成功),函数返回0;
    //否:当前线程进入信号量的等待队列,阻塞暂停(排队等退票),直到被sem_post()唤醒。
    //被唤醒后,重新执行 “检查 + 减 1”(比如有人退票,计数器+1后>0,就减 1 买票)。
    //返回值:成功返回0,失败返回-1(比如被信号中断)。
    //对应例子:电影院剩余票 = 0,观众 A 调用sem_wait()会直接排队;
    //等观众 B 退票(sem_post()),观众 A 被唤醒,买票成功。
    //那么这个就是和上面所说的一样

    //然后就是V操作,也就是上面所说的归还信号量的操作
    //sem_post() —— 归还信号量(“退票,喊排队的人来买”)
    //函数原型:
    //int sem_post(sem_t *sem);
    //具体操作(原子性):
    //信号量计数器+1(退票成功,剩余票变多);
    //检查等待队列是否有线程:
    //有:随机唤醒一个(或按排队顺序,看系统),让它继续申请信号量;
    //无:啥也不做(没人排队,不用喊)。
    //返回值:成功返回0,失败返回-1(比如信号量超最大值,错误码EOVERFLOW)。
    //关键注意:
    //必须先sem_wait()(买票)再sem_post()(退票),否则会导致计数器超最大值(比如没买票就退票,电影院拒绝)。
    //这个也是和上面所说的归还信号量的操作一样

    // P 操作:对应荷兰语 “Proberen”(发音近似 “普洛贝伦”),意思是 “尝试”“探测”;
    // V 操作:对应荷兰语 “Verhogen”(发音近似 “费尔霍亨”),意思是 “增加”“提升”。

    //这里也得说明一下,V操作和P操作都是原子性的
    //也就是说在V/P操作没有进行完之前,是不会被任何操作干扰的

    //比较常用的信号量接口函数就是上面这些
    //那么能理解信号量的本质的话,其实信号量这一个知识点还是很好理解的
    //那么在这里我还得说明一下,因为无论是线程申请信号量还是归还信号量
    //那么本质上它们都得先看到信号量才行,也就是都得能先访问到信号量才行
    //所以,信号量,也是一个共享资源!!!
    //这里进行一个扩展,上面说的都是信号量设定的最大容量大于1的情况,要是给信号量设定的最大容量就是1呢?
    //这是什么???就是互斥量!!!就是mutex锁!!!!!!!!
    //那么mutex的上锁相当于是什么呢?就是信号量的sem_wait函数
    //只有占据了那一个信号量的线程才能访问sem_wait下的代码块
    //其他线程都得阻塞等待,不能去访问,那么这不就是对应锁的上锁操作吗!!!
    //那么mutex的解锁操作呢?就是信号量的sem_post函数
    //归还信号量,信号量由0变为1,代表允许线程去进行访问了
    //那么不就是相当于锁的解锁操作吗!!!
    //我们把设定的最大容量就是1的信号量叫做二元互斥信号量,这一点也要理解哦

    //那么在这里再扩展一下,信号量和条件变量的区别是什么呢?

    //信号量与条件变量的核心区别解析
    //核心结论:信号量是 "带计数器的资源管理器",条件变量是 "纯通知器",定位和用法差异显著

    /* 一、本质定位差异 */
    //信号量:自带整数计数器的资源管理工具,直接统计 "剩余可用资源数",兼具同步 + 计数功能
    //条件变量:纯通知机制,不管理资源 / 计数,仅负责 "通知等待线程:条件已满足",需搭配其他工具使用

    /* 二、使用依赖差异 */
    //信号量:可独立使用(如互斥信号量直接当锁),无需额外同步工具
    //条件变量:必须绑定互斥锁(pthread_mutex_t),否则会出现数据竞争或 "虚假唤醒"

    /* 三、等待目标差异 */
    //信号量:等待 "资源可用"(计数器 > 0),无需关心资源可用的原因,有资源就直接获取
    //条件变量:等待 "特定条件成立"(如 "缓冲区非空"" 有空位 "),需主动检查条件,不满足才等待

    /* 四、唤醒机制差异 */
    //信号量:sem_post () 仅唤醒等待队列中的一个线程,且唤醒后线程可直接获取资源
    //条件变量:支持两种唤醒方式 ——// 1. pthread_cond_signal ():唤醒一个等待线程// 2. pthread_cond_broadcast ():唤醒所有等待线程(适合多线程等同一条件)

    /* 五、资源计数能力差异 */
    //信号量:自带资源计数功能,可直接统计剩余资源数量(如缓冲区空位、可用连接数)
    //条件变量:无计数功能,需自定义共享变量(如 int empty_seats)并通过互斥锁保护

    /* 六、适用场景差异 */
    //信号量适用场景:
    //- 需要管理具体资源数量(如生产者 – 消费者的缓冲区计数)
    //- 简单互斥 / 同步(如线程间独占访问资源)
    //- 进程间同步(命名信号量支持跨进程)
    //条件变量适用场景:
    //- 需要等待复杂条件(如 "数据处理完成"" 队列不为空 ")
    //- 需要批量唤醒等待线程(如广播通知所有等待者)
    //- 纯通知场景(无需计数,仅需 "告诉" 线程干活)
    /* 关键总结 */
    //1. 管资源数量→用信号量,等条件通知→用条件变量;
    //2. 信号量更 "全能"(自带计数),条件变量更 "灵活"(适合复杂条件);
    //3. 条件变量必须配互斥锁,信号量可独立使用。

    //那么总结一下就是说,条件变量需要借助锁的配合,而且条件变量的条件判断是需要我们自己进行的
    //还得注意在调用pthread_cond_wait函数的时候使用while循环
    //而且条件变量的唤醒函数也是需要我们进行条件判断
    //那么信号量不用,它自己就会进行判断
    //当我们申请信号量和归还信号量的时候,它自己就会判断说信号量的值是否满足对应要求
    //而且信号量自己就带有锁的功能,而条件变量没有锁的话,那么可能会出现多个线程访问共享资源的情况
    //具体参考之前写的条件变量的示例函数,要是把上锁和解锁去掉的话,那么会是什么后果呢,很明显
    //这里就简单说明一下,条件变量的判断是不是要访问共享资源,那么按道理是不是也要保护起来呢?
    //那么要是没锁的话,不就一堆线程都进入到条件判断,要是通过条件判断,那么都阻塞了
    //而要是没通过,直接就一堆线程都进入对共享资源的修改了,那么此时的条件变量就是形同虚设!!!
    //而信号量则不会,只要信号量为0,那么你申请信号量的线程就一定会阻塞,管你有没有锁的
    //就一定暂时无法去访问共享资源
    //而且信号量的归还信号量函数,不仅能随机唤醒一个等待的线程,其实还是相当于让线程得以去访问临界区
    //而条件变量的话,就需要唤醒函数的调用,然后还得解锁,然后其他线程才能去竞争锁去访问临界区
    //那么最主要的是,信号量能统计共享资源中剩余可访问资源的个数
    //这就是条件变量做不到的一点,也是最大的一个差距
    //条件变量:
    //“先拿锁,再 while 看条件,不成立就 wait,成立就改条件,最后signal/broadcast+解锁”
    //信号量:
    //“P 拿资源(可能阻塞),V 还资源(唤醒一个),资源计数器内置,无需 while

    // 1. 定义信号量(互斥用,初始值1)和共享资源
    sem_t mutex; // 信号量:作为互斥锁
    int ticket_count = 5; // 共享资源:剩余票数

    // 2. 线程函数:模拟抢票
    void *buy_ticket(void *arg)
    {
    int id = *(int*)arg; // 获取线程ID

    while (1)
    {
    // P操作:申请信号量(上锁)
    sem_wait(&mutex);

    // 临界区:访问共享资源
    if (ticket_count > 0)
    {
    printf("线程%d:抢到第%d张票\\n", id, ticket_count);
    ticket_count–;
    sleep(1); // 模拟操作耗时
    } else
    {
    sem_post(&mutex); // 释放信号量(避免死锁)
    break; // 票抢完了,退出循环
    }

    // V操作:归还信号量(解锁)
    sem_post(&mutex);
    sleep(1); // 模拟线程切换
    }

    return NULL;
    }

    int main()
    {
    // 3. 初始化信号量:线程共享,初始值1(互斥锁)
    sem_init(&mutex, 0, 1);

    // 4. 创建两个抢票线程
    pthread_t t1, t2;
    int id1 = 1, id2 = 2;
    pthread_create(&t1, NULL, buy_ticket, &id1);
    pthread_create(&t2, NULL, buy_ticket, &id2);

    // 5. 等待线程结束
    pthread_join(t1, NULL);
    pthread_join(t2, NULL);

    // 6. 销毁信号量
    sem_destroy(&mutex);

    printf("所有票已抢完!\\n");
    return 0;
    }

    // 1. 定义信号量(初始值=3,代表3个停车位)和共享变量
    sem_t parking_sem; // 停车位信号量
    int car_id = 0; // 车辆ID(用于标识不同车辆)

    // 2. 线程函数:模拟车辆停车+离开
    void *car_behavior(void *arg)
    {
    int id = ++car_id; // 分配车辆ID
    printf("车辆%d:到达停车场\\n", id);

    // P操作:申请停车位(信号量–,剩余车位减少)
    sem_wait(&parking_sem);
    printf("车辆%d:成功停车(剩余车位(信号量):%d)\\n", id, get_sem_value(&parking_sem));

    sleep(3); // 模拟停车时长

    // V操作:离开停车场(信号量++,剩余车位增加)
    sem_post(&parking_sem);
    printf("车辆%d:离开停车场(剩余车位(信号量):%d)\\n", id, get_sem_value(&parking_sem));

    return NULL;
    }

    int main() {
    // 3. 初始化信号量:线程共享,初始值=3(3个停车位)
    sem_init(&parking_sem, 0, 3);

    // 4. 创建5辆车的线程(超过停车位数量,模拟排队)
    pthread_t cars[5];
    for (int i = 0; i < 5; i++)
    {
    pthread_create(&cars[i], NULL, car_behavior, NULL);
    sleep(1); // 让车辆分批到达
    }

    // 5. 等待所有车辆线程结束
    for (int i = 0; i < 5; i++)
    {
    pthread_join(cars[i], NULL);
    }

    // 6. 销毁信号量
    sem_destroy(&parking_sem);

    printf("停车场关闭!\\n");
    return 0;
    }

    // 辅助函数:获取信号量当前值(方便打印剩余车位)
    // 换个名字避免冲突,比如叫get_sem_value
    int get_sem_value(sem_t *sem)
    {
    int val;
    // 检查系统函数是否调用成功
    if (sem_getvalue(sem, &val) == -1) //POSIX标准库中本来就有sem_getvalue函数,它的作用是:获取信号量当前的计数值
    {
    perror("获取信号量值失败");
    return -1; // 失败返回-1
    }
    return val; // 成功返回信号量值
    }

    对于POSIX信号量的封装:

    #include <semaphore.h>
    #include <iostream>
    #include <unistd.h>
    #include <cstring>
    #include <cerrno>

    // 那么在本文件其实就是对信号量的一系列函数进行一个封装
    // 封装出一个信号量类出来,方便我们后面的使用

    // P 操作:对应荷兰语 “Proberen”(发音近似 “普洛贝伦”),意思是 “尝试”“探测”;
    // V 操作:对应荷兰语 “Verhogen”(发音近似 “费尔霍亨”),意思是 “增加”“提升”。

    namespace semaphore
    {
    class Sem
    {
    public:
    // 禁用拷贝构造和赋值运算符(信号量是不可拷贝的资源)
    Sem(const Sem&) = delete;
    Sem& operator=(const Sem&) = delete;

    // 构造函数
    Sem(const int &n) // 那么因为要在构造函数调用sem_init函数,所以需要外界传入信号量的初始值
    {
    // 调用sem_init函数
    int ret_sem_init = sem_init(&_sem, 0, n);
    if (ret_sem_init == -1)
    {
    std::cerr << "信号量初始化失败:" << strerror(errno) << std::endl;
    }
    }
    // 析构函数
    ~Sem()
    {
    // 那么也就是调用信号量的销毁函数
    int ret_sem_destroy = sem_destroy(&_sem);
    if (ret_sem_destroy == -1)
    {
    std::cerr << "信号量销毁失败:" << strerror(errno) << std::endl;
    }
    }
    // 进行P操作的函数,即申请信号量的操作
    // 本质就是sem_wait函数
    void P()
    {
    int ret = sem_wait(&_sem);
    if (ret == -1)
    {
    std::cerr << "信号量P操作失败:" << strerror(errno) << std::endl;
    }
    }
    // 进行V操作的函数,即归还信号量的操作
    // 本质就是sem_post函数
    void V()
    {
    int ret = sem_post(&_sem);
    if (ret == -1)
    {
    std::cerr << "信号量V操作失败:" << strerror(errno) << std::endl;
    }
    }
    private:
    sem_t _sem; // 信号量变量
    };
    }

    结语:以信号量为钥,解锁多线程同步的核心密码

    亲爱的读者朋友们,当你读到这里,想必已经陪着这篇万字长文走完了 POSIX 信号量的完整学习之旅。从最初对 “计数器” 的模糊认知,到深入理解其 “资源预定器” 的本质,再到亲手拆解 P/V 操作的原子逻辑、玩转两大实战案例、理清与互斥锁 / 条件变量的核心差异 —— 我相信,此刻的你,已经不再是那个对多线程同步感到迷茫的初学者,而是真正掌握了信号量这把关键工具的开发者。

    首先,我想真心为你点个赞。在这个追求 “碎片化学习” 的时代,能沉下心来啃完一篇万字技术长文,本身就是一种难得的坚持。多线程编程向来是 C++ 开发中的 “拦路虎”,而信号量作为同步工具中的 “多面手”,既要理解其底层逻辑,又要掌握实际用法,还要避开各种隐藏的坑,确实需要花一番功夫。但你做到了 —— 你没有满足于表面的函数调用,而是跟着我的思路深挖本质;你没有畏惧复杂的代码案例,而是逐行拆解理解逻辑;你没有混淆相似的同步工具,而是通过对比理清了边界。这份钻研精神,正是技术成长路上最宝贵的财富。

    回顾整个学习过程,我们其实一直在做一件事:把抽象的技术概念,拉回到真实的生活场景中。信号量不是冰冷的 “整数计数器”,而是电影院里的售票系统,是停车场的入口管理员 —— 它默默统计着剩余的资源,公平地安排线程的 “排队” 与 “入场”,既保证了资源的有序使用,又避免了混乱与冲突。而 P/V 操作也不是生硬的 “减一”“加一”,而是我们生活中 “买票” 与 “退票” 的逻辑复刻:有资源就直接占用,没资源就耐心等待,用完后及时归还,还不忘唤醒排队的人。这种 “从生活中来,到技术中去” 的理解方式,正是破解复杂概念的万能钥匙。

    我始终认为,学习编程的核心不是背诵函数原型,也不是死记硬背用法,而是理解 “为什么”—— 为什么信号量要设计成原子操作?因为多线程环境下 “计数混乱” 会导致资源竞争;为什么 P/V 操作必须成对出现?因为 “只借不还” 会导致死锁,“只还不借” 会导致资源统计失效;为什么信号量能兼顾互斥与同步?因为它自带的计数器让它既能 “锁住” 资源(二元信号量),又能 “限流” 访问(计数信号量)。想通了这些 “为什么”,你就不再是 “机械地使用工具”,而是 “理解工具的设计者思路”,这才是真正的掌握。

    在实际开发中,信号量的价值远比我们在案例中展示的更强大。当你需要设计一个连接池,限制同时访问数据库的线程数量时,计数信号量会是你的得力助手;当你需要实现线程池中的任务队列同步时,二元信号量可以轻松实现生产者与消费者的互斥访问;当你需要控制多个线程对共享缓冲区的读写顺序时,信号量的同步能力能帮你避免数据竞争。而更重要的是,掌握了信号量的逻辑后,你再去学习其他同步工具(比如条件变量、读写锁)时,会发现它们之间的底层逻辑是相通的 —— 都是为了解决 “多线程有序访问共享资源” 这个核心问题,只是适用场景不同而已。

    当然,学习之路从无止境。信号量只是多线程编程的一个缩影,在实际项目中,你还会遇到死锁排查、优先级反转、性能优化等更复杂的问题。但请记住,任何复杂的问题都可以拆解成我们学过的基础知识点。就像我们在 “避坑指南” 中提到的,只要你牢记 “P/V 成对出现”“处理信号中断”“把握初始化与销毁时机” 这几个核心原则,就能避开大部分信号量使用的陷阱;只要你能分清 “什么时候用信号量,什么时候用条件变量,什么时候用互斥锁”,就能在不同场景中做出最优选择。

    我还记得自己刚学信号量时,也曾对着 “原子操作”“等待队列” 这些概念头疼不已,直到我把它和电影院买票的场景联系起来,才突然恍然大悟。所以,如果你在后续的学习中遇到了困惑,不妨停下来,找一个生活中的类比,把技术问题 “翻译” 成日常场景,答案往往会豁然开朗。同时,一定要多动手实践 —— 把我们的案例代码敲一遍,修改参数看看结果变化,甚至尝试用信号量实现一个简单的生产者 – 消费者模型,只有在实践中,你才能真正掌握工具的用法,才能应对各种突发情况。

    最后,我想对你说:编程是一场漫长的修行,没有捷径可走,但每一步坚持都不会白费。今天你花在信号量上的时间,会成为你未来开发多线程程序时的底气;今天你理解的 “资源预定” 逻辑,会帮你快速掌握更复杂的同步机制;今天你培养的 “拆解问题、联系实际” 的思维,会让你在面对任何新技术时都游刃有余。

    或许此刻的你,还只是刚刚入门多线程编程,或许你已经在项目中遇到过同步问题,但请相信,只要你保持这份对技术的热爱与钻研,不断积累、不断实践,就一定能在编程的道路上越走越远。信号量只是你技术工具箱中的一把钥匙,未来你还会拥有更多强大的工具,但请永远记住:工具是为了解决问题而生的,只有理解了问题的本质,才能用好工具。

    愿你在未来的开发之路上,既能用信号量这样的基础工具搭建稳固的同步架构,也能灵活驾驭各种高级同步机制;既能从容应对多线程编程中的各种挑战,也能始终保持对技术的好奇与热情。编程的世界很大,值得我们用一生去探索;技术的深度无穷,等待我们不断去挖掘。加油,亲爱的开发者!祝你在代码的海洋中乘风破浪,收获属于自己的成长与成就!

    赞(0)
    未经允许不得转载:171主机测评 » 对于Linux:POSIX信号量以及封装信号量的解析
    分享到: 更多 (0)

    评论 抢沙发

    • 昵称 (必填)
    • 邮箱 (必填)
    • 网址