百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分析 > 正文

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

liebian365 2024-11-03 15:46 30 浏览 0 评论

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

  1. 等待(wait)
  2. 发送信号(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;
}
 //两个进程相互制约,而达到资源的有效使用。

运行结果:

相关推荐

“版本末期”了?下周平衡补丁!国服最强5套牌!上分首选

明天,酒馆战棋就将迎来大更新,也聊了很多天战棋相关的内容了,趁此机会,给兄弟们穿插一篇构筑模式的卡组推荐!老规矩,我们先来看10职业胜率。目前10职业胜率排名与一周前基本类似,没有太多的变化。平衡补丁...

VS2017 C++ 程序报错“error C2065:“M_PI”: 未声明的标识符&quot;

首先,程序中头文件的选择,要选择头文件,在文件中是没有对M_PI的定义的。选择:项目——>”XXX属性"——>配置属性——>C/C++——>预处理器——>预处理器定义,...

东营交警实名曝光一批酒驾人员名单 88人受处罚

齐鲁网·闪电新闻5月24日讯酒后驾驶是对自己和他人生命安全极不负责的行为,为守护大家的平安出行路,东营交警一直将酒驾作为重点打击对象。5月23日,东营交警公布最新一批饮酒、醉酒名单。对以下驾驶人醉酒...

Qt界面——搭配QCustomPlot(qt platform)

这是我第一个使用QCustomPlot控件的上位机,通过串口精确的5ms发送一次数据,再将读取的数据绘制到图表中。界面方面,尝试卡片式设计,外加QSS简单的配了个色。QCustomPlot官网:Qt...

大话西游2分享赢取种族坐骑手办!PK趣闻录由你书写

老友相聚,仗剑江湖!《大话西游2》2021全民PK季4月激燃打响,各PK玩法鏖战齐开,零门槛参与热情高涨。PK季期间,不仅各种玩法奖励丰厚,参与PK趣闻录活动,投稿自己在PK季遇到的趣事,还有机会带走...

测试谷歌VS Code AI 编程插件 Gemini Code Assist

用ClaudeSonnet3.7的天气测试编码,让谷歌VSCodeAI编程插件GeminiCodeAssist自动编程。生成的文件在浏览器中的效果如下:(附源代码)VSCode...

顾爷想知道第4.5期 国服便利性到底需优化啥?

前段时间DNF国服推出了名为“阿拉德B计划”的系列改版计划,截至目前我们已经看到了两项实装。不过关于便利性上,国服似乎还有很多路要走。自从顾爷回归DNF以来,几乎每天都在跟我抱怨关于DNF里面各种各样...

掌握Visual Studio项目配置【基础篇】

1.前言VisualStudio是Windows上最常用的C++集成开发环境之一,简称VS。VS功能十分强大,对应的,其配置系统较为复杂。不管是对于初学者还是有一定开发经验的开发者来说,捋清楚VS...

还嫌LED驱动设计套路深?那就来看看这篇文章吧

随着LED在各个领域的不同应用需求,LED驱动电路也在不断进步和发展。本文从LED的特性入手,推导出适合LED的电源驱动类型,再进一步介绍各类LED驱动设计。设计必读:LED四个关键特性特性一:非线...

Visual Studio Community 2022(VS2022)安装图文方法

直接上步骤:1,首先可以下载安装一个VisualStudio安装器,叫做VisualStudioinstaller。这个安装文件很小,很快就安装完成了。2,打开VisualStudioins...

Qt添加MSVC构建套件的方法(qt添加c++11)

前言有些时候,在Windows下因为某些需求需要使用MSVC编译器对程序进行编译,假设我们安装Qt的时候又只是安装了MingW构建套件,那么此时我们该如何给现有的Qt添加一个MSVC构建套件呢?本文以...

Qt为什么站稳c++GUI的top1(qt c)

为什么现在QT越来越成为c++界面编程的第一选择,从事QT编程多年,在这之前做C++界面都是基于MFC。当时为什么会从MFC转到QT?主要原因是MFC开发界面想做得好看一些十分困难,引用第三方基于MF...

qt开发IDE应该选择VS还是qt creator

如果一个公司选择了qt来开发自己的产品,在面临IDE的选择时会出现vs或者qtcreator,选择qt的IDE需要结合产品需求、部署平台、项目定位、程序猿本身和公司战略,因为大的软件产品需要明确IDE...

Qt 5.14.2超详细安装教程,不会来打我

Qt简介Qt(官方发音[kju:t],音同cute)是一个跨平台的C++开库,主要用来开发图形用户界面(GraphicalUserInterface,GUI)程序。Qt是纯C++开...

Cygwin配置与使用(四)——VI字体和颜色的配置

简介:VI的操作模式,基本上VI可以分为三种状态,分别是命令模式(commandmode)、插入模式(Insertmode)和底行模式(lastlinemode),各模式的功能区分如下:1)...

取消回复欢迎 发表评论: