linux应用 进程间通信之信号量(System V)

news2024/10/5 23:29:12

1、定义

System V 信号量是一种用于进程间同步和互斥的机制,它是 System V IPC(Inter-Process Communication,进程间通信)机制的一部分。信号量通常用于控制对共享资源的访问,以避免竞争条件(race condition)和数据不一致性。

一般来说,System V 信号量常用于以下场景:

  • 进程同步:多个进程需要协调执行顺序,例如在生产者-消费者问题中,生产者和消费者需要同步对共享缓冲区的访问。
  • 资源互斥:多个进程需要互斥地访问共享资源,例如文件、打印机、设备等。
  • 进程间通信:信号量也可以用于进程间的通信,通过信号量的值来进行信息传递。:

优点:

  • 高效性:信号量是一种轻量级的同步机制,适用于对共享资源的快速访问和控制。
  • 多种同步操作:信号量支持多种同步操作,包括 P(等待)操作和 V(释放)操作,可以灵活地控制对资源的访问。
  • 可扩展性:信号量可以用于控制多个资源的访问,适用于复杂的同步和互斥场景。

缺点:

  • 复杂性:与其他进程间通信机制相比,信号量的使用可能更为复杂,容易出现死锁等问题。

重要概念:

  • P 操作:P 操作用于请求进入临界区(临界区是一段代码,一次只允许一个进程进入执行)。如果信号量的值大于 0,那么执行 P 操作会将信号量的值减 1,并允许进程进入临界区执行。如果信号量的值已经为 0,那么执行 P 操作的进程会被阻塞,直到信号量的值变为非零为止。
  • V 操作:V 操作用于离开临界区。执行 V 操作会将信号量的值加 1。如果有其他进程因为执行 P 操作而被阻塞,那么执行 V 操作会唤醒其中一个被阻塞的进程。

2、常用接口介绍

2.1 编程常用接口和数据结构

2.1.1 ftok函数

ftok函数用于生成一个System V IPC对象(如消息队列、共享内存等)的key。它将pathname和proj_id组合起来,生成一个唯一的key,用于标识一个System V IPC对象。

key_t ftok(const char *pathname, int proj_id);
  • 入参:pathname是一个路径名,proj_id是一个用户指定的整数。
  • 返回值:返回一个基于pathname和proj_id生成的key。
2.1.2 semget函数

semget 用于创建一个新的信号量集或者获取一个已存在的信号量集。

int semget(key_t key, int nsems, int semflg);
  • 入参:key用于标识信号量集的键值,通常使用 ftok 函数生成,nsems信号量集中包含的信号量数量,semflg:用于指定信号量的权限和标志,通常使用 IPC_CREAT 来创建一个新的信号量集。
  • 返回值:返回一个信号量集的标识符(semid)。
2.1.3 semctl函数

semctl 用于对信号量集进行控制操作,比如初始化、获取值、设置值、删除等。

int semctl(int semid, int semnum, int cmd, ...);
  • 入参:semid信号量集的标识符,semnum信号量的索引,通常为 0,cmd:控制命令,用于指定要进行的操作,比如 SETVAL 用于设置信号量的值,... 根据不同的命令,可能会有额外的参数。
  • 返回值:根据不同的命令,返回不同的值。

cmd取值如下:

  • GETVAL:获取信号量的值
  • SETVAL:设置信号量的值
  • GETPID:获取上次执行 semop 操作的进程ID
  • GETNCNT:获取当前等待信号量值增加的进程数
  • GETZCNT:获取当前等待信号量值减少的进程数
  • GETALL:获取所有信号量的值
  • SETALL:设置所有信号量的值
  • IPC_RMID:删除信号量

当第三个参数为 SETVAL 时,需要第四个参数,第四个参数是一个 union semun 结构体类型的变量,用于指定要设置的信号量的值。

当第三个参数为 SETALL 时,需要第四个参数,第四个参数是一个指向 short 类型数组的指针,数组的长度等于信号量集中的信号量数量,用于指定要设置的所有信号量的值。

2.1.4 semop函数

semop 用于执行对信号量的操作,比如等待(P操作)和释放(V操作)。

int semop(int semid, struct sembuf *sops, unsigned nsops);
  • 入参:semid信号量集的标识符,sops指向一个 sembuf 结构体数组的指针,每个 sembuf 结构体描述了一个操作,nsops:sops 数组中结构体的数量。
  • 返回值:成功返回 0,失败返回 -1。
2.1.5 struct sembuf
struct sembuf {
    unsigned short sem_num;  // 信号量在信号量集中的索引
    short sem_op;             // 操作值,可以是正数(V操作)或负数(P操作)
    short sem_flg;            // 操作标志位,可以使用 IPC_NOWAIT 等标志
};
sem_op sem_flg 结果影响
正数执行 V(释放)操作,增加信号量的值。如果信号量的值非负,就会唤醒等待该信号量的进程。操作成功返回,否则返回失败。
负数执行 P(等待)操作,减少信号量的值。如果信号量的值小于 0,就会阻塞等待直到信号量的值变为非负。操作成功返回,否则返回失败。
0执行 Z(等待直到值为 0)操作,等待信号量的值变为 0。如果信号量的值不为 0,就会阻塞等待。操作成功返回,否则返回失败。
任意IPC_NOWAIT如果操作无法立即进行,就会立即返回,而不是阻塞等待。如果操作成功返回,否则返回失败。
任意SEM_UNDO系统会跟踪对信号量的修改,并在进程终止时撤销这些修改,以防止进程异常终止导致信号量的值不一致。如果操作成功返回,否则返回失败。
2.1.6 union semun
union semun {
    int val;              // 用于设置单个信号量的值
    struct semid_ds *buf; // 用于获取或设置信号量集的属性
    unsigned short *array; // 用于设置所有信号量的值
} arg;

struct semid_ds {
    struct ipc_perm sem_perm; // 信号量集的权限信息
    time_t sem_otime; // 上次操作时间
    time_t sem_ctime; // 上次修改时间
    unsigned short sem_nsems; // 信号量集中的信号量数量
};

struct ipc_perm {
    key_t key; // IPC 对象的键值
    uid_t uid; // 所有者的用户ID
    gid_t gid; // 所有者的组ID
    uid_t cuid; // 创建者的用户ID
    gid_t cgid; // 创建者的组ID
    mode_t mode; // 权限
};

2.2 控制台常用命令

2.2.1 ipcs

ipcs命令用于显示系统中的IPC资源信息,包括消息队列、共享内存和信号量。-s选项表示只显示信号量的信息:

ipcs -s
2.2.2 ipcrm

ipcrm命令用于删除指定的 IPC 对象,包括信号量:

ipcrm -s <semid>

3、编程示例

测试代码如下:

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <string.h>
#include <sys/msg.h>
#include <unistd.h>
#include <fcntl.h>
#include <time.h>

#define SEM_FILE_PATH "/home/sem"
#define INIT_NUM 2

// 打印时分秒的宏        
#define PRINT_MIN_SEC() do { \
            time_t t = time(NULL); \
            struct tm *tm_ptr = localtime(&t); \
            printf("%02d:%02d:%02d:", tm_ptr->tm_hour, tm_ptr->tm_min, tm_ptr->tm_sec); \
        } while (0)

int main(int argc, char *argv[]) 
{
    key_t key;
    int semid;
    struct sembuf sops = {0};

    // 文件不存在则创建文件
    if (-1 == access(SEM_FILE_PATH, F_OK))
    {
        system("touch "SEM_FILE_PATH);
    }

    // 获取key
    if((key = ftok(SEM_FILE_PATH, 'a')) < 0)
    {
        return 0;
    }

    // 创建一个信号量集
    semid = semget(key, 1, IPC_CREAT | 0666); 


    // 命令行参数 
    // 第一个参数      P表示P操作 V表示V操作 I表示设置初始值为INIT_NUM D表示删除
    if (argc != 2) 
    {
        printf("Usage: %s P|V|I|D", argv[0]);
        return 0;
    }


    if (!strcmp(argv[1], "P"))
    {
        PRINT_MIN_SEC();
        printf("*****P Opt*****\n");
        sops.sem_num = 0;
        sops.sem_op = -1; // P 操作
        sops.sem_flg = 0;
        
        semop(semid, &sops, 1); // 执行 P 操作
        PRINT_MIN_SEC();
        printf("!!!Inter P Zero!!!\n");
    } 
    else if (!strcmp(argv[1], "V")) 
    {
        PRINT_MIN_SEC();
        printf("*****V Opt*****\n");
        sops.sem_num = 0;
        sops.sem_op = 1; // V 操作
        sops.sem_flg = 0;
        semop(semid, &sops, 1); // 执行 V 操作
    } 
    else if (!strcmp(argv[1], "I")) 
    {
        PRINT_MIN_SEC();
        printf("*****Init Opt*****\n");
        // 设置信号量的值
        union semun {
            int val;
            struct semid_ds *buf;
            unsigned short *array;
        } arg;
        arg.val = INIT_NUM;
        semctl(semid, 0, SETVAL, arg);
    } 
    else if (!strcmp(argv[1], "D")) 
    {
        PRINT_MIN_SEC();
        printf("*****Delete Opt*****\n");
        semctl(semid, 0, IPC_RMID);
    } 
    else
    {
        printf("Usage: %s P|V|I|D", argv[0]);
        return 0;
    }


    // 执行完操作后打印状态
    struct semid_ds seminfo;
    semctl(semid, 0, IPC_STAT, &seminfo);
    PRINT_MIN_SEC();
    printf("SME Value: %d\n", semctl(semid, 0, GETVAL));
    PRINT_MIN_SEC();
    printf("SME Mode: %o\n", seminfo.sem_perm.mode);
    PRINT_MIN_SEC();
    printf("SME Create User ID: %d\n", seminfo.sem_perm.uid);

    return 0;
}

运行程序时根据命令行参数的不同执行不同操作:P表示P操作 V表示V操作 I表示设置初始值为INIT_NUM D表示删除,首先执行初始化,并查询:

代码中P操作执行sops.sem_op = -1,初始值为2可以满足两次P操作,第三次P操作进入阻塞:

另起一个终端执行V操作,此时第三次P操作可以获取到信号量完成后续:

测试删除:

4、总结

本文阐述了进程间通信之信号量(System V)的定义,列举了编程中使用的接口和linux命令,编写了测试用例测试相关功能。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1444157.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【EAI 017】Interactive Language: Talking to Robots in Real Time

论文标题&#xff1a;Interactive Language: Talking to Robots in Real Time 论文作者&#xff1a;Corey Lynch, Ayzaan Wahid, Jonathan Tompson Tianli Ding, James Betker, Robert Baruch, Travis Armstrong, Pete Florence 作者单位&#xff1a;Robotics at Google 论文原…

口腔助手|口腔挂号预约小程序|基于微信小程序的口腔门诊预约系统的设计与实现(源码+数据库+文档)

口腔小程序目录 目录 基于微信小程序的口腔门诊预约系统的设计与实现 一、前言 二、系统功能设计 三、系统实现 1、小程序前台界面实现 2、后台管理员模块实现 四、数据库设计 1、实体ER图 2、具体的表设计如下所示&#xff1a; 五、核心代码 六、论文参考 七、最新…

【软件设计师】——面向对象设计原则

为了提高软件的可维护性、可复用性&#xff0c;增加软件的可扩展性和灵活性&#xff0c;在面向对象编程的过程中我们需要遵守以下六条原则。 开闭原则 定义&#xff1a; 编写的代码需要对 扩展开放 对 修改关闭 &#xff0c;实现 热插拔 的效果。 例&#xff1a;在编写不同皮…

【Web】小白友好的Java内存马基础学习笔记

目录 简介 文件马与内存马的比较 文件马原理 内存马原理 内存马使用场景 内存马分类 内存马注入方式 这篇文章主要是概念性的&#xff0c;具体技术细节不做探究&#xff0c;重点在祛魅。 简介 内存马&#xff08;Memory Shellcode&#xff09;是一种恶意攻击技术&…

【Linux】学习-动静态库

动静态库 头文件与库的区别 头文件一般而言&#xff0c;是声明和宏定义。头文件是在预处理阶段使用的 库文件是已经编译好的二进制代码。是一种目标文件&#xff0c;库文件是在链接阶段使用的 对于头文件和库我们可以这样理解&#xff0c;就是头文件提供的是一个函数的声明&…

Hive正则表达式

Hive版本&#xff1a;hive-3.1.2 一、Hive的正则表达式概述 正则表达式是一种用于匹配和操作文本的强大工具&#xff0c;它是由一系列字符和特殊字符组成的模式&#xff0c;用于描述要匹配的文本模式。 Hive的正则表达式灵活使用解决HQL开发过程中的很多问题&#xff0c;本篇文…

基于SpringBoot+Vue的服装销售商城系统

末尾获取源码作者介绍&#xff1a;大家好&#xff0c;我是墨韵&#xff0c;本人4年开发经验&#xff0c;专注定制项目开发 更多项目&#xff1a;CSDN主页YAML墨韵 学如逆水行舟&#xff0c;不进则退。学习如赶路&#xff0c;不能慢一步。 目录 一、项目简介 二、开发技术与环…

无人机系统组装与调试,多旋翼无人机组装与调试技术详解,无人机飞控系统原理

多旋翼无人机飞控系统的组装 在开始组装前&#xff0c;确保您已准备好所有必要的工具和材料。这包括螺丝刀、电烙铁、焊台、杜邦线、飞控板、GPS模块、电机、桨叶等。 飞控安装 安全开关安装&#xff0c;将安全开关固定在机架上。将安全开关的线插到飞控SWITCH插口上。 电调…

如何从 iPhone 恢复已删除的视频:简单有效方法

无论您是在尝试释放空间时不小心删除了 iPhone 上的视频&#xff0c;还是在出厂时清空了手机&#xff0c;现在所有数据都消失了&#xff0c;都不要放弃。有一些方法可以恢复这些视频。 在本文中&#xff0c;我们将向您展示六种最有效的数据恢复方法&#xff0c;可以帮助您从 i…

直播app开发,技术驱动的实时互动新纪元

随着互联网技术的快速发展&#xff0c;直播已成为我们日常生活的重要组成部分。从娱乐、教育到商业活动&#xff0c;直播的广泛应用正在改变着我们的生活和工作方式。在这一变革中&#xff0c;直播开发扮演着至关重要的角色。本文将探讨直播开发的核心理念、技术挑战以及未来的…

离散数学——图论(笔记及思维导图)

离散数学——图论&#xff08;笔记及思维导图&#xff09; 目录 大纲 内容 参考 大纲 内容 参考 笔记来自【电子科大】离散数学 王丽杰

PacketSpy:一款功能强大的网络数据包嗅探、捕捉和分析工具

关于PacketSpy PacketSpy是一款功能强大的网络数据包嗅探工具&#xff0c;在该工具的帮助下&#xff0c;广大研究人员可以轻松捕捉并分析目标网络系统中的流量。PacketSpy提供了跟网络流量安全相关的全面功能&#xff0c;可以用于检查HTTP请求与响应、查看原始Payload数据、以…

web前后端小坑记录

游戏服务器过年这段时间忙完了&#xff0c;好久没看web了&#xff0c;重温一下。发现竟然没有文章记录这些修BUG的过程&#xff0c;记录一下。 目录 如何处理F5刷新&#xff1f; 如何处理F5刷新&#xff1f; 后端应该发现路由不存在&#xff0c;直接返回打包好的index.html就…

腾讯云4核8G服务器够用吗?容纳多少人同时访问?

腾讯云4核8G服务器支持多少人在线访问&#xff1f;支持25人同时访问。实际上程序效率不同支持人数在线人数不同&#xff0c;公网带宽也是影响4核8G服务器并发数的一大因素&#xff0c;假设公网带宽太小&#xff0c;流量直接卡在入口&#xff0c;4核8G配置的CPU内存也会造成计算…

steam搬砖项目免费分享,学会即可上手

亲身体验过很多互联网微创业项目&#xff0c;steam搬砖项目我愿称之为最强副业&#xff01;如果你每天有1-2小时的空闲时间&#xff0c;那我非常建议你试试这个。两个平台之间搬运下装备就能进账&#xff0c;努力点月入几千还是完全没问题的。 steam搬砖怎么赚钱&#xff1f;做…

【Spring框架】Spring事务同步

目录 一、什么是Spring事务同步 二、 事务同步管理器 2.1 TransactionSynchronizationManager事务同步管理器 2.1.1 资源同步 2.1.2 事务同步 2.1.3 总结 三、事务同步管理器保障事务的原理 四、spring事务为何使用TransactionSynchronizationManager spring源码实现 …

哪家洗地机比较好用?性能好的洗地机推荐

在众多功能中&#xff0c;我坚信洗地机的核心依旧是卓越的清洁能力以及易于维护的便捷性&#xff0c;其他的附加功能可以看作是锦上添花&#xff0c;那么如何找到性能好的洗地机呢&#xff1f;我们一起看看哪些洗地机既能确保卫生效果还能使用便利。 洗地机工作原理&#xff1…

【leetcode热题100】子集 II

给你一个整数数组 nums &#xff0c;其中可能包含重复元素&#xff0c;请你返回该数组所有可能的子集&#xff08;幂集&#xff09;。 解集 不能 包含重复的子集。返回的解集中&#xff0c;子集可以按 任意顺序 排列。 示例 1&#xff1a; 输入&#xff1a;nums [1,2,2] 输出…

基于javaEE的ssm仓库管理系统

仓库管理系统的重中之重是进销存分析这一板块&#xff0c;在这一板块中&#xff0c;顾名思义能够查询到近期的进货记录&#xff0c;包括每日的进货单据&#xff0c;单品推移(即某一商品的库存变化)&#xff0c;方便我们核对库存差异。同时也需要查询到每日的销售数据&#xff0…

Linux服务器安装Jenkins

1、安装Jenkins前必须先安装jdk与maven 2、下载Jenkins 安装包地址 linux jenkins 链接: 百度网盘 请输入提取码 提取码: zfyq 3、解压压缩包 rpm -ivh jenkins-2.174-1.1.noarch.rpm 4、解压完成后查看Jenkins安装路径 whereis jenkins 5、启动报错 &#xff0c;这是因为Jenki…