1. 信号量简介

信号量用于进程或线程间同步，Posix信号量是一个非负整型，只有两种操作，加一(sem_post)和减一(sem_wait)，如果信号量值为0，sem_wait默认阻塞。

Posix信号量有两种，有名信号量和无名信号量，顾名思义，就是是否有名字。有名信号量有一个名字，长度不超过NAME_MAX-4(i.e. 251)，因为内核会默认加上'sem.'，所以这里要减4，名字以斜杠开头'/'，后面跟上一个或多个非斜杠字符。不同进程可以通过同一个名字来操作有名信号量，sem_open用于创建或者获取已存在的信号量，创建好之后就可以使用sem_post或者sem_wait来操作。使用完之后可以使用sem_close来关闭信号量，sem_unlink用来删除信号量，删除并不立即销毁，只有当所有进程都sem_close才开始销毁。

无名信号量没有名字，基于内存，通常用在同一个进程线程之间或者不同进程的共享内存里，因为同一个进程的不同线程共享进程地址空间，所以可以访问到，放到共享内存里也可以被不同进程访问到。使用前必须使用sem_init进行初始化，初始化之后就可以使用sem_wait和sem_post操作，使用完成后sem_destroy接口进行销毁，下一节介绍接口的使用

2. 信号量API接口

2.1 有名信号量创建

#include <fcntl.h>           /* For O_* constants */
#include <sys/stat.h>        /* For mode constants */
#include <semaphore.h>/**
* @brief 创建或获取有名信号量
*
* @params name 有名信号量关联的名字，斜杠开头，长度不超过NAME_MAX-4(e.g. 251)
* @params oflag 标志位，可选值包括O_CREAT| O_EXCL
* 这里如果指定了O_CREAT标志位，还要填写额外两个参数，mode和value
*
* @params mode，参考open函数，通常填0即可
* @params value 信号量的初始值
* @returns 成功返回描述符，失败返回-1
**/sem_t *sem_open(const char *name, int oflag);
sem_t *sem_open(const char *name, int oflag,mode_t mode, unsigned int value);# 编译加上 -pthread选项
Link with -pthread.

2.2 信号量减一操作

#include <semaphore.h>/**
* @brief lock信号量并减1，当信号量大于0，操作可以执行，否则则阻塞。如果设置了NONBLOCK标志位，则报错返回
*
* @params sem 信号量描述符
* @returns 成功返回0，失败返回-1
**/
int sem_wait(sem_t *sem);/**
* @brief 同sem_wait，只不过如果无法减1则立即报错返回
*
**/
int sem_trywait(sem_t *sem);/**
* @brief 同sem_wait，只不过如果无法减1则会等待一段时间，注意这里时间参数要设置正确
*
**/
int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);# 编译链接选项 -pthread
Link with -pthread.

2.3 信号量加1操作

#include <semaphore.h>/**
* @brief 信号量的值加1
*
* @params sem 信号量文件描述符
* @returns 成功返回0，失败返回-1
**/int sem_post(sem_t *sem);# 编译链接选项 -pthread
Link with -pthread.

2.4 关闭有名信号量

#include <semaphore.h>/**
* @brief 关闭信号量，系统为当前进程分配的信号量资源会被释放。
*
* @params sem 信号量文件描述符
* @returns 成功返回0，失败返回-1
**/int sem_close(sem_t *sem);# 编译链接选项 -pthread
Link with -pthread.

2.5 销毁有名信号量

#include <semaphore.h>/**
* @brief 销毁信号量，只有当所有进程都关闭信号量之后才开始销毁工作
*
* @params name 信号量名字
* @returns 成功返回0，失败返回-1
**/int sem_unlink(const char *name);# 编译链接选项 -pthread
Link with -pthread.

2.6 初始化无名信号量

#include <semaphore.h>/**
* @brief 初始化无名信号量
*
* @params sem 待初始化的信号量地址
* @params pshared 为0表示线程间共享，非0表示进程间共享
* @params value 信号量初始值，不超过SEM_VALUE_MAX
* @returns 成功返回0，失败返回-1
**/int sem_init(sem_t *sem, int pshared, unsigned int value);# 编译链接选项 -pthread
Link with -pthread.

2.7 销毁无名信号量

#include <semaphore.h>/**
* @brief 销毁无名信号量
*
* @params sem 要销毁的信号量
* 如果有其它线程或进程阻塞在sem上，此时销毁会产生未定义的行为
*
* @returns 成功返回0，失败返回-1
**/int sem_destroy(sem_t *sem);# 编译链接选项 -pthread
Link with -pthread.

3 有名信号量例子

3.1 信号量生产者


// 生产者
#include <fcntl.h>           /* For O_* constants */
#include <sys/stat.h>        /* For mode constants */
#include <semaphore.h>
#include <errno.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>#define SEM_NAME "/sem0"int main(int argc, char** argv)
{if (argc < 3){printf("Usage: ./sem_post timeval nums\n");return -1;}int ts = atoi(argv[1]);int total = atoi(argv[2]);if (total < 1 || ts < 1){printf("invalid param\n");return -1;}sem_t* sem_id;// 创建信号量并初始化值为0sem_id = sem_open(SEM_NAME, O_CREAT, O_RDWR, 0);if (sem_id == SEM_FAILED){perror("sem_open error");return -1;}int curr = 0;while (curr < total){        // 生成信号量，即加1while (sem_post(sem_id)){perror("sem_post error, try later");sleep(1);}printf("producing succ\n");sleep(ts);++curr;}printf("work done\n");// 关闭信号量sem_close(sem_id);return 0;
}

3.2 信号量消费者


// 消费者
#include <fcntl.h>           /* For O_* constants */
#include <sys/stat.h>        /* For mode constants */
#include <semaphore.h>
#include <errno.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>#define SEM_NAME "/sem0"int main()
{sem_t* sem_id;// 创建信号量并初始化值为0sem_id = sem_open(SEM_NAME, O_CREAT, O_RDWR, 0);if (sem_id == SEM_FAILED){perror("sem_open error");return -1;}while (1){// 消费信号量if (sem_wait(sem_id)){perror("sem_wait fail, try later\n");sleep(1);continue;}printf("consuming succ\n");}// 关闭信号量sem_close(sem_id);return 0;
}

3.3 编译&运行

default:gcc -o sem_post sem_post.c -pthreadgcc -o sem_wait sem_wait.c -pthread
clean:rm -rf sem_wait sem_post

4. 无名信号量例子

创建两个线程，分别用于生产和消费

#include <semaphore.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>// 消费者
void* consumer_worker(void *arg)
{sem_t *sem = arg;while (1){// 消费信号量if (sem_wait(sem)){perror("[consumer] sem_wait error, try later\n");sleep(1);continue;}printf("[consumer] consume succ\n");}return 0;
}// 生产者
void* producer_worker(void *arg)
{sem_t *sem = arg;while (1){// 生成信号量if (sem_post(sem)){perror("[producer] sem_post error, try later\n");sleep(1);continue;}printf("[producer] produce succ\n");sleep(1);}return 0;
}int main(int argc, char** argv)
{pthread_t consumer, producer;if (argc < 2){printf("Usage: ./unnamed_sem time\n");return -1;}int tm = atoi(argv[1]);if (tm < 1){printf("invalid param\n");return -1;}sem_t sem;// 无名信号量初始化if (sem_init(&sem, 0, 0)){perror("sem_init error");return -1;}// 创建生产者线程if (pthread_create(&producer, NULL, &producer_worker, (void *)&sem)){perror("create producer_worker error");sem_destroy(&sem);return -1;}// 创建消费者线程if (pthread_create(&consumer, NULL, &consumer_worker, (void *)&sem)){perror("create consumer_worker error");sem_destroy(&sem);return -1;}printf("main thread sleep:%d\n", tm);sleep(tm);// 无名信号量销毁sem_destroy(&sem);return 0;
}

5. 参考资料

1. https://www.man7.org/linux/man-pages/man7/sem_overview.7.html

2. 《Linux环境编程从应用到内核》

================================================================================================

Linux应用程序、内核、驱动、后台开发交流讨论群(745510310)，感兴趣的同学可以加群讨论、交流、资料查找等，前进的道路上，你不是一个人奥^_^。

Linux进程间通信五 Posix 信号量简介与示例相关推荐

linux进程间通信：POSIX信号量
文章目录概念描述编程接口注意事项编程案例信号量基本接口使用案例信号量父子进程间通信信号量实现两进程之间通信概念描述英文:semaphore 简称SEM,主要用来进行进程间同步本质 ...
linux进程间通信：POSIX 消息队列 ----异步通信
在上一篇中linux进程间通信:POSIX 消息队列我们知道消息队列中在消息个数达到了队列所能承载的上限,就会发生消息的写阻塞. 阻塞式的通信影响系统效率,进程之间在通信收到阻塞时并不能去做其他事情, ...
Linux进程间通信三 System V 信号量简介与示例
1. System V信号量简介 SystemV信号量主要用于解决生产者和消费者问题,一个信号量能够控制多个资源,说它是信号量集也不为过. 2. API接口介绍 2.1 创建或打开信号量集 #incl ...
linux进程间通信：POSIX 共享内存
文章目录思维导图通信原理优势 POSIX 共享内存编程接口编程案例思维导图之前学习过sysemV 的共享内存的实现及使用原理,参考linux进程间通信:system V 共享内存 POS ...
Linux进程同步之POSIX信号量
POSIX信号量是属于POSIX标准系统接口定义的实时扩展部分.在SUS(Single UNIX Specification)单一规范中,定义的XSI IPC中也同样定义了人们通常称为System V ...
linux进程间通信：POSIX 消息队列
文章目录基本介绍相关编程接口编程实例消息队列通信实例消息队列属性设置实例基本介绍关于消息队列的基本介绍,前面在学习system V的消息队列时已经有过了解,linux进程间通信:syst ...
linux网络编程-posix信号量与互斥锁（39）
-posix信号量信号量是打开一个有名的信号量 sem_init是打开一个无名的信号量,无名信号量的销毁用sem_destroy sem_wait和sem_post是对信号量进行pv操作,既可以使用 ...
Linux进程间通信六 Posix 共享内存简介与示例
1. 共享内存简介共享内存主要用于不同进程之间相互通信,因为操作的是同一块地址,不需要内核和用户层之间数据拷贝,属于最快的进程间通信方式,不过,为了防止读写冲突,一般需要额外的同步手段.之前介绍了S ...
Linux进程间通信四 Posix 消息队列简介与示例
目录 1. Posix 消息队列简介 2. API接口 2.1 创建或打开消息队列 2.2 发送消息 2.3 接收消息 2.4 获取.设置消息队列属性 2.5 关闭消息队列 2.6 删除消息队列 2. ...

Linux进程间通信五 Posix 信号量简介与示例