💎一站式轻松地调用各大LLM模型接口,支持GPT4、智谱、星火、月之暗面及文生图 广告
[TOC] # 简介 信号量广泛用于进程或线程间的同步和互斥,信号量本质上是一个非负的整数计数器,它被用来控制对公共资源的访问。 编程时可根据操作信号量值的结果判断是否对公共资源具有访问的权限,当信号量值大于 0 时,则可以访问,否则将阻塞。 PV 原语是对信号量的操作,一次 P 操作使信号量减1,一次 V 操作使信号量加1。 信号量主要用于进程或线程间的同步和互斥这两种典型情况。 信号量数据类型为:sem\_t。 信号量用于互斥 ![](https://img.kancloud.cn/78/40/7840184c1741b897b05dac7b00602560_466x412.png) 信号量用于同步: ![](https://img.kancloud.cn/47/83/4783558814a374e3a6af0c2d97cab132_642x491.png) # sem_init函数 初始化信号量: ~~~ #include <semaphore.h> ​ int sem_init(sem_t *sem, int pshared, unsigned int value); 功能: 创建一个信号量并初始化它的值。一个无名信号量在被使用前必须先初始化。 参数: sem:信号量的地址。 pshared:等于 0,信号量在线程间共享(常用);不等于0,信号量在进程间共享。 value:信号量的初始值。 返回值: 成功:0 失败: - 1 ~~~ # sem_destroy函数 销毁信号量: ~~~ #include <semaphore.h> ​ int sem_destroy(sem_t *sem); 功能: 删除 sem 标识的信号量。 参数: sem:信号量地址。 返回值: 成功:0 失败: - 1 ~~~ ​ # 信号量P操作(减1) ~~~ #include <semaphore.h> ​ int sem_wait(sem_t *sem); 功能: 将信号量的值减 1。操作前,先检查信号量(sem)的值是否为 0,若信号量为 0,此函数会阻塞,直到信号量大于 0 时才进行减 1 操作。 参数: sem:信号量的地址。 返回值: 成功:0 失败: - 1 ​ int sem_trywait(sem_t *sem); * 以非阻塞的方式来对信号量进行减 1 操作。 * 若操作前,信号量的值等于 0,则对信号量的操作失败,函数立即返回。 ​ int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout); * 限时尝试将信号量的值减 1 * abs_timeout:绝对时间 ~~~ abs_timeout补充说明: ~~~ struct timespec { time_t tv_sec; /* seconds */ // 秒 long tv_nsec; /* nanosecondes*/ // 纳秒 } ​ time_t cur = time(NULL); //获取当前时间。 struct timespec t; //定义timespec 结构体变量t t.tv_sec = cur + 1; // 定时1秒 sem_timedwait(&cond, &t); ~~~ # 信号量V操作(加1) ~~~ #include <semaphore.h> ​ int sem_post(sem_t *sem); 功能: 将信号量的值加 1 并发出信号唤醒等待线程(sem_wait())。 参数: sem:信号量的地址。 返回值: 成功:0 失败:-1 ~~~ # 获取信号量的值 ~~~ #include <semaphore.h> ​ int sem_getvalue(sem_t *sem, int *sval); 功能: 获取 sem 标识的信号量的值,保存在 sval 中。 参数: sem:信号量地址。 sval:保存信号量值的地址。 返回值: 成功:0 失败:-1 ~~~ # 例子 ~~~ sem_t sem; //信号量 void printer(char *str) { sem_wait(&sem);//减一 while (*str) { putchar(*str); fflush(stdout); str++; sleep(1); } printf("\n"); ​ sem_post(&sem);//加一 } ​ void *thread_fun1(void *arg) { char *str1 = "hello"; printer(str1); } ​ void *thread_fun2(void *arg) { char *str2 = "world"; printer(str2); } ​ int main(void) { pthread_t tid1, tid2; ​ sem_init(&sem, 0, 1); //初始化信号量,初始值为 1 ​ //创建 2 个线程 pthread_create(&tid1, NULL, thread_fun1, NULL); pthread_create(&tid2, NULL, thread_fun2, NULL); ​ //等待线程结束,回收其资源 pthread_join(tid1, NULL); pthread_join(tid2, NULL); ​ sem_destroy(&sem); //销毁信号量 ​ return 0; } ~~~ # 扩展 自旋锁 > int pthread\_spin\_destroy(pthread\_spinlock\_t \*lock); > > int pthread\_spin\_init(pthread\_spinlock\_t \*lock, int pshared); 屏障 信号量: > int semget(key\_t key, int nsems, int semflg);