信号量函数 (semget、semctl、semop)及示例
liebian365 2024-11-03 15:46 9 浏览 0 评论
Linux进程间通信之信号量(semaphore)是变量,是一种特殊的变量。它紧取正值。对信息号量的操作只有2中:
- 等待(wait)
- 发送信号(signal)
信号量比较难理解。下面我们一个个的看一下各个函数。与信号量处理的函数有:semget();semctl();semop();
第一个semget()函数
与共享内存的shmget()函数类似。
使用格式:
#include<sys/sem.h>
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<stdio.h>
#include<sys/sem.h>
#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<sys/sem.h>
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<sys/sem.h>
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<stdio.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<stdlib.h>
#include<sys/stat.h>
#include<sys/sem.h>
#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<stdio.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<stdlib.h>
#include<sys/sem.h>
#include<string.h>
#include<sys/stat.h>
#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;
}
//两个进程相互制约,而达到资源的有效使用。
运行结果:
相关推荐
- 快递查询教程,批量查询物流,一键管理快递
-
作为商家,每天需要查询许许多多的快递单号,面对不同的快递公司,有没有简单一点的物流查询方法呢?小编的回答当然是有的,下面随小编一起来试试这个新技巧。需要哪些工具?安装一个快递批量查询高手快递单号怎么快...
- 一键自动查询所有快递的物流信息 支持圆通、韵达等多家快递
-
对于各位商家来说拥有一个好的快递软件,能够有效的提高自己的工作效率,在管理快递单号的时候都需要对单号进行表格整理,那怎么样能够快速的查询所有单号信息,并自动生成表格呢?1、其实方法很简单,我们不需要一...
- 快递查询单号查询,怎么查物流到哪了
-
输入单号怎么查快递到哪里去了呢?今天小编给大家分享一个新的技巧,它支持多家快递,一次能查询多个单号物流,还可对查询到的物流进行分析、筛选以及导出,下面一起来试试。需要哪些工具?安装一个快递批量查询高手...
- 3分钟查询物流,教你一键批量查询全部物流信息
-
很多朋友在问,如何在短时间内把单号的物流信息查询出来,查询完成后筛选已签收件、筛选未签收件,今天小编就分享一款物流查询神器,感兴趣的朋友接着往下看。第一步,运行【快递批量查询高手】在主界面中点击【添...
- 快递单号查询,一次性查询全部物流信息
-
现在各种快递的查询方式,各有各的好,各有各的劣,总的来说,还是有比较方便的。今天小编就给大家分享一个新的技巧,支持多家快递,一次能查询多个单号的物流,还能对查询到的物流进行分析、筛选以及导出,下面一起...
- 快递查询工具,批量查询多个快递快递单号的物流状态、签收时间
-
最近有朋友在问,怎么快速查询单号的物流信息呢?除了官网,还有没有更简单的方法呢?小编的回答当然是有的,下面一起来看看。需要哪些工具?安装一个快递批量查询高手多个京东的快递单号怎么快速查询?进入快递批量...
- 快递查询软件,自动识别查询快递单号查询方法
-
当你拥有多个快递单号的时候,该如何快速查询物流信息?比如单号没有快递公司时,又该如何自动识别再去查询呢?不知道如何操作的宝贝们,下面随小编一起来试试。需要哪些工具?安装一个快递批量查询高手快递单号若干...
- 教你怎样查询快递查询单号并保存物流信息
-
商家发货,快递揽收后,一般会直接手动复制到官网上一个个查询物流,那么久而久之,就会觉得查询变得特别繁琐,今天小编给大家分享一个新的技巧,下面一起来试试。教程之前,我们来预览一下用快递批量查询高手...
- 简单几步骤查询所有快递物流信息
-
在高峰期订单量大的时候,可能需要一双手当十双手去查询快递物流,但是由于逐一去查询,效率极低,追踪困难。那么今天小编给大家分享一个新的技巧,一次能查询多个快递单号的物流,下面一起来学习一下,希望能给大家...
- 物流单号查询,如何查询快递信息,按最后更新时间搜索需要的单号
-
最近有很多朋友在问,如何通过快递单号查询物流信息,并按最后更新时间搜索出需要的单号呢?下面随小编一起来试试吧。需要哪些工具?安装一个快递批量查询高手快递单号若干怎么快速查询?运行【快递批量查询高手】...
- 连续保存新单号功能解析,导入单号查询并自动识别批量查快递信息
-
快递查询已经成为我们日常生活中不可或缺的一部分。然而,面对海量的快递单号,如何高效、准确地查询每一个快递的物流信息,成为了许多人头疼的问题。幸运的是,随着科技的进步,一款名为“快递批量查询高手”的软件...
- 快递查询教程,快递单号查询,筛选更新量为1的单号
-
最近有很多朋友在问,怎么快速查询快递单号的物流,并筛选出更新量为1的单号呢?今天小编给大家分享一个新方法,一起来试试吧。需要哪些工具?安装一个快递批量查询高手多个快递单号怎么快速查询?运行【快递批量查...
- 掌握批量查询快递动态的技巧,一键查找无信息记录的两种方法解析
-
在快节奏的商业环境中,高效的物流查询是确保业务顺畅运行的关键。作为快递查询达人,我深知时间的宝贵,因此,今天我将向大家介绍一款强大的工具——快递批量查询高手软件。这款软件能够帮助你批量查询快递动态,一...
- 从复杂到简单的单号查询,一键清除单号中的符号并批量查快递信息
-
在繁忙的商务与日常生活中,快递查询已成为不可或缺的一环。然而,面对海量的单号,逐一查询不仅耗时费力,还容易出错。现在,有了快递批量查询高手软件,一切变得简单明了。只需一键,即可搞定单号查询,一键处理单...
- 物流单号查询,在哪里查询快递
-
如果在快递单号多的情况,你还在一个个复制粘贴到官网上手动查询,是一件非常麻烦的事情。于是乎今天小编给大家分享一个新的技巧,下面一起来试试。需要哪些工具?安装一个快递批量查询高手快递单号怎么快速查询?...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- wireshark怎么抓包 (75)
- qt sleep (64)
- cs1.6指令代码大全 (55)
- factory-method (60)
- sqlite3_bind_blob (52)
- hibernate update (63)
- c++ base64 (70)
- nc 命令 (52)
- wm_close (51)
- epollin (51)
- sqlca.sqlcode (57)
- lua ipairs (60)
- tv_usec (64)
- 命令行进入文件夹 (53)
- postgresql array (57)
- statfs函数 (57)
- .project文件 (54)
- lua require (56)
- for_each (67)
- c#工厂模式 (57)
- wxsqlite3 (66)
- dmesg -c (58)
- fopen参数 (53)
- tar -zxvf -c (55)
- 速递查询 (52)