Linux进程间通信之信号量(semaphore)是变量，是一种特殊的变量。它紧取正值。对信息号量的操作只有2中：

等待（wait）
发送信号（signal）

信号量比较难理解。下面我们一个个的看一下各个函数。与信号量处理的函数有：semget();semctl();semop();

第一个semget（）函数

与共享内存的shmget（）函数类似。

使用格式：

#include
int? semget(key_t? _key ,int? _nsems,int _semflg);

功能：创建一个新的信号量或获取一个已经存在的信号量的键值。

返回值：成功返回信号量的标识码ID。失败返回-1；

参数：

_key 为整型值，用户可以自己设定。有两种情况：

1、键值是IPC_PRIVATE，该值通常为0，意思就是创建一个仅能被进程进程给我的信号量。

2、键值不是IPC_PRIVATE，我们可以指定键值，例如1234；也可以一个ftok()函数来取得一个唯一的键值。

_nsems 表示初始化信号量的个数。比如我们要创建一个信号量，则该值为1.,创建2个就是2。

_semflg ：信号量的创建方式或权限。有IPC_CREAT，IPC_EXCL。

IPC_CREAT如果信号量不存在，则创建一个信号量，否则获取。

IPC_EXCL只有信号量不存在的时候，新的信号量才建立，否则就产生错误。

下面我们看个小例子：

#include
#include
#define MYKEY 6666
int main()
{
?
??????? int semid;
??????? semid=semget(MYKEY,1,IPC_CREAT|0666);//创建了一个权限为666的信号量
??????? printf("semid=%d\n",semid);
??????? return 0;
}

运行结果为：

我们可以用ipcs –s 来查看是否创建成功。

用ipcrm -s semid号来删除指定的信号量。

需要C/C++ Linux服务器架构师学习资料私信“资料”（资料包括C/C++，Linux，golang技术，Nginx，ZeroMQ，MySQL，Redis，fastdfs，MongoDB，ZK，流媒体，CDN，P2P，K8S，Docker，TCP/IP，协程，DPDK，ffmpeg等），免费分享

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

第二个函数semctl（）

这是控制信号量的函数，在这个函数中我们可以删除信号量或初始化信号量。

格式：

#include
int? semctl(int _semid? ,int _semnum,int _cmd? ……);

功能：控制信号量的信息。

返回值：成功返回0，失败返回-1；

参数：

_semid 信号量的标志码(ID)，也就是semget（）函数的返回值;

_semnum, 操作信号在信号集中的编号。从0开始。

_cmd 命令，表示要进行的操作。

下面列出的这些命令来源于百度！

参数cmd中可以使用的命令如下：

IPC_STAT读取一个信号量集的数据结构semid_ds，并将其存储在semun中的buf参数中。

IPC_SET设置信号量集的数据结构semid_ds中的元素ipc_perm，其值取自semun中的buf参数。

IPC_RMID将信号量集从内存中删除。

GETALL用于读取信号量集中的所有信号量的值。

GETNCNT返回正在等待资源的进程数目。

GETPID返回最后一个执行semop操作的进程的PID。

GETVAL返回信号量集中的一个单个的信号量的值。

GETZCNT返回这在等待完全空闲的资源的进程数目。

SETALL设置信号量集中的所有的信号量的值。

SETVAL设置信号量集中的一个单独的信号量的值。

Semunion ;第4个参数是可选的；semunion :是union semun的实例。

union semun {
?? int?? val;
?? struct?? semid_ds? *buf;
?? unsigned short?? *arrary;
};
//下面是给一个信号量初始化的代码。
??????? union semun ?sem_args;
??????? unsigned short array[1]={1};
??????? sem_args.array = array;
??????? ret = semctl(semid, 0, SETALL, sem_args);//0代表对1个信号来量初始化，即有1个资源
??????? ?if (-1 == ret)
??????? {
??????????????? perror("semctl");
??????????????? exit(EXIT_FAILURE);
??????? }

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

第三个函数 semop()

格式：

#include
int??? semop(int ? semid ,struct??? sembuf?? *_sops ,size_t? _nsops);

功能：用户改变信号量的值。也就是使用资源还是释放资源使用权。

返回值：成功返回0，失败返回-1；

参数：

_semid : 信号量的标识码。也就是semget（）的返回值。

_sops是一个指向结构体数组的指针。

?struct?? sembuf{
???? unsigned short? sem_num;//第几个信号量，第一个信号量为0；
???? short? sem_op;//对该信号量的操作。
???? short _semflg;
};

sem_num: 操作信号在信号集中的编号。第一个信号的编号为0；

sem_op : 如果其值为正数，该值会加到现有的信号内含值中。通常用于释放所控资源的使用权；如果sem_op的值为负数，而其绝对值又大于信号的现值，操作将会阻塞，直到信号值大于或等于sem_op的绝对值。通常用于获取资源的使用权；如果sem_op的值为0，则操作将暂时阻塞，直到信号的值变为0。

_semflg IPC_NOWAIT //对信号的操作不能满足时，semop()不会阻塞，并立即返回，同时设定错误信息。

IPC_UNDO //程序结束时(不论正常或不正常)，保证信号值会被重设为semop()调用前的值。这样做的目的在于避免程序在异常情况下结束时未将锁定的资源解锁，造成该资源永远锁定。

nsops：操作结构的数量，恒大于或等于1。

下面看个例子：

源文件1：

#include
#include
#include
#include
#include
#include
?
#define SEM_KEY 6666
?
union semun {
??? int setval;
??? struct semid_ds *buf;
??? unsigned short *array;
};
?
?
int main(int argc ,char *argv[])
{
?
??? int? shmid;
??? float?? *addr;
??? float h,w;
??? shmid= shmget(ftok(".",1000),getpagesize(),IPC_CREAT? | 0666);//创建一个共享内存，权限为0666
??? printf("shmid=%d\n",shmid);
??? if(shmid==-1)
??? {
?????? perror("shmget error:");
?????? exit(EXIT_FAILURE);
??? }
??? addr=shmat(shmid,0,0);//获取共享内存的起始地址，且为可读可写
??? if(-1==*addr)
??? {
?????? perror("shmat error:");
?????? exit(EXIT_FAILURE);
??? }
?
??? int semid;
??? int ret;
??? semid = semget(SEM_KEY, 2, IPC_CREAT | 0600);//创建2个信号量
??? if (-1 == semid)
??? {
?????? perror("semget");
?????? exit(EXIT_FAILURE);
??? }
??? printf("semid = %d\n", semid);
?//?? 初始化2个信号量
??? union semun sem_args;
??? unsigned short array[2]={1,1};
??? sem_args.array = array;
??? ret = semctl(semid, 1, SETALL, sem_args);//SETALL代表设置信号集中所有的信号量的值。1,代表2个，sem_args是具体初始化的值放在共用体中。
??? if (-1 == ret)
??? {
?????? perror("semctl");
?????? exit(EXIT_FAILURE);
??? }
//对资源的使用处理操作
??? struct sembuf sem_opt_wait1[1] = {0, -1, SEM_UNDO};
??? struct sembuf sem_opt_wakeup1[1] = {0, 1, SEM_UNDO};
??? struct sembuf sem_opt_wait2[1] = {1, -1, SEM_UNDO};
??? struct sembuf sem_opt_wakeup2[1] = {1, 1, SEM_UNDO};
?
??? while(1)
??? {
?????? semop(semid, sem_opt_wait2, 1);//获取进程2的资源，让进程2等待
?????? printf(" enter you height(CM) and height(KG):\n");
?????? scanf("%f%f",addr,addr+1);
?????? semop(semid, sem_opt_wakeup1, 1);//唤醒进程1，即释放资源的使用权
?????? if(*addr==1||*(addr+1)==1 ) break;//如果输入身高是1或体重是1就退出
??? }
?
??? return 0;
}

源程序2：

#include
#include
#include
#include
#include
#include
#include
?
#define SEM_KEY 6666
?
union semun {
??? int setval;
??? struct semid_ds *buf;
??? unsigned short *array;
};
?
?
int main(int argc ,char *argv[])
{
?
??? int? shmid;
??? float? *addr;
??? float h,w;
??? shmid= shmget(ftok(".",1000),getpagesize(), IPC_CREAT | 0666);//打开刚才原程序1创建的共享内存，权限为0666
??????? printf("shmid=%d\n",shmid);
??? if(shmid==-1)
??? {
?
?????? perror("shmget error:");
?????? exit(EXIT_FAILURE);
??? }
??? addr =shmat(shmid,0,0);//获取共享内存的起始地址，且为可读可写
??? if(-1== *addr)
??? {
?????? perror("shmat error:");
?????? exit(EXIT_FAILURE);
??? }
?
??? int semid;
??? int ret;
??? semid = semget(SEM_KEY, 0, IPC_CREAT | 0600););//取得信号量
??? if (-1 == semid)
??? {
?????? perror("semget");
?????? exit(EXIT_FAILURE);
??? }
??? printf("semid = %d\n", semid);
?
//对资源的使用处理操作
??? struct sembuf sem_opt_wait1[1] = {0, -1, SEM_UNDO};
??? struct sembuf sem_opt_wakeup1[1] = {0, 1, SEM_UNDO};
??? struct sembuf sem_opt_wait2[1] = {1, -1, SEM_UNDO};
??? struct sembuf sem_opt_wakeup2[1] = {1, 1, SEM_UNDO};
?
??? while(1)
??? {
?????? semop(semid, sem_opt_wait1, 1);//获取进程1的资源好让进程1等待。
?????? h=*addr;
?????? w=*(addr+1);
??????????????? printf("h=%f\tw=%f\n",h,w);
??? ??? if(h==1.0 || w==1.0) break;;//如果输入身高是1或体重是1就退出
?????? int ret=w/(h*h/10000);
?????? if(ret>=20 &&ret <=25)
?????? {
?????????? printf("ok!\n");
?????? }else if(ret <20)
?????? {
?????????? printf("thin!\n");
?
?????? } else
?????? {
?????????? printf("fat!\n");
?????? }
?????? semop(semid, sem_opt_wakeup2, 1);//释放进程2的资源，即唤醒进程2
?
??? }
?????? if(-1==semctl(semid,1,IPC_RMID,0))//删除信号量
?????? {
?????? perror("semctl error:");
?????? exit(EXIT_FAILURE);
??????? }
??? if(-1==shmdt(addr))//释放共享内存，使其不再有任何指向它的指针
??? {
?????? perror("shmdt error:");
?????? exit(EXIT_FAILURE);
?
??? }
??? if (shmctl(shmid,IPC_RMID,0)==-1)//删除共享内存
??? {
?????? perror("shctl error:");
?????? exit(EXIT_FAILURE);
??? }
?
?
??? return 0;
}
?//两个进程相互制约，而达到资源的有效使用。

运行结果：

信号量函数 (semget、semctl、semop)及示例

第一个semget（）函数

第二个函数semctl（）

第三个函数 semop()

相关推荐

为什么有人认为Linux不如macOS?

linux系统实用篇-8、系统配置与优化

Linux中如何启用root用户

如何远程执行Linux命令和脚本?大技霸来教你

Windows如何远程linux(桌面版)

6款Linux常用远程连接工具，你最中意哪一款?

如何使用 Linux find 命令查找文件?

Rackspace的所有平台将支持Ubuntu Linux

这次答应我，一举拿下 I/O 多路复用

Linux新手入门系列:Linux远程访问