网络编程:多进程和多线程编程

news2025/2/1 1:42:35

1. 多进程编程

1.1 fork

#include <sys/types.h>
#include <unistd.h>
// 调用失败返回 -1 设置 errno
pid_t fork( void );

子进程返回 0,父进程返回子进程 PID;

信号位图被清除(父进程的信号处理函数不再对新进程起作用)

1.2 exec 系列系统调用

替换当前进程映像,一般情况下不会返回,出错后返回 -1 并设置 errno;

注意:exec 函数不会关闭原程序打开的文件描述符,除非该 fd 设置了 SOCK_CLOEXEC 属性;

1.3 处理僵尸进程

#include <sys/types.h>
#include <sys/wait.h>
// 调用失败返回 -1 设置 errno
pid_t wait( int* stat_loc );
pid_t waitpid( pid_t pid, int* stat_loc. int options );

waitpid 只等待 pid 指定的子进程;pid 取值为 -1,和 wait 相同,等待任意一个子进程结束;
options 取值是 WNOHANG 时,waitpid 是非阻塞的:pid 指定的子进程没有结束或意外终止,立即返回 0;子进程正常退出,返回子进程 PID;

1.4 信号量

1.4.1 semget

创建一个新的信号量集,或者获取一个已经存在的信号量集;

#include <sys/sem.h>
// 成功返回一个正整数,标识信号量集
// 失败返回 -1 设置 errno
int semget( key_t key, int num_sems. int sem_flags );

key 用来标识一个全局唯一的信号量集;传递特殊键值 IPC_PRIVATE(值为 0)可以保证总是创建新的信号量集;
num_sems 指定信号量集中信号量的数目;(若是创建,必须指定;若是获取,设为 0)
sem_flags 指定该信号量的权限, 后 9 位与open中的 mode 一致;

#include <sys/sem.h>
struct ipc_perm
{
	key_t key;		/* 键值 */
	uid_t uid;		/* 所有者的有效用户 ID */
	gid_t gid;		/* 所有者的有效组 ID */
	uid_t cuid;		/* 创建者的有效用户 ID */
	gid_t cgid;		/* 创建者的有效组 ID */
	mode_t mode;	/* 访问权限 */
					/* 省略其他填充字段 */
};

struct semid_ds
{
	struct ipc_perm sem_perm;		/* 信号量的操作权限 */
	unsigned long int sem_nsems;	/* 信号量集的信号量数目 */
	time_t sem_otime;				/* 最后一次调用 semop 的时间 */
	time_t sem_ctime;				/* 最后一次调用 semctl 的时间 */
									/* 键值 */
};	

semid_ds 是与信号量集相关联的内核数据结构,semget作用是创建并初始化它,会将 sem_otime 设为 0,sem_ctime 设为当前系统时间;

1.4.2 semop

改变信号量的值,是原子操作;

unsigned short semval;			/* 信号量的值 */
unsigned short semzcnt;			/* 等待信号值变为 0 的进程数量 */
unsigned short semncnt;			/* 等待信号值增加的进程数量 */
pid_t sempid;					/* 最后一次执行 semop 操作的进程 ID */
int semop( int sem_id, struct sembuf* sem_ops, size_t num_sem_ops );

sem_id 是 semget返回的信号量集标识符;sem_ops 指向 sembuf 数组;

struct sembuf
{
	unsigned short int sem_num;
	short int sem_op;
	short int sem_flg;
}

sem_num 为信号集中信号量的编号;

在这里插入图片描述
SEM_UNDO 的含义是,当进程退出时取消正在进行的 semop 操作,会更新进程的 semadj 变量,,来跟踪进程对信号量的修改情况;

1.4.3 semctl

对信号量直接控制

int semctl( int sem_id, int sem_num, int command, ... );

command 为要执行的命令,有些命令需要第 4 个参数,推荐如下形式

union semun
{
	int val;					/*用于 SETVAL 命令*/
	struct semid_ds* buf;		/*用于 IPC_STAT 和 IPC_SET 命令*/
	unsigned short* array;		/*用于 GETALL 和 SETALL 命令*/
	struct seminfo* __buf;		/*用于 IPC_INFO 命令*/
};

常用命令为

命令含义成功时返回值
IPC_RMID移除信号量集,唤醒所有等待该信号量集的进程(semop返回错误,errno 为 EIDRM)0
SETVAL将信号量的值设为 semun.val ,同时内核数据中的 semid_ds.sem_ctime 被更新0

1.5 共享内存

最高效的 IPC 机制;

1.5.1 shmget

创建一段新的共享内存或获取一段已经存在的共享内存;

#include <sys/shm.h>
// 成功返回正整数,为共享内存的标识;失败返回 -1 设置 errno
int shmget( key_t key, size_t size, int shmflg );

这三个参数与 semget含义相同,size 指定共享内存的大小,单位是字节;
shmflg 支持额外的两个标志:

  • SHM_HUGETLB;系统使用“大页面”分配共享内存,类似于 mmap的 MAP_HUGETLB 标志;
  • SHM_NORESERVE;不为共享内存保留交换分区,类似于 mmap的 MAP_NORESERVE 标志;这样当物理内存不足时,对该共享内存执行写操作将触发 SIGSEGV 信号;

shmget创建共享内存,所有字节都被初始化为 0,与之关联的内核数据结构为 shmid_ds 被创建和初始化;

struct shmid_ds
{
	struct ipc_perm shm_perm;	/* 共享内存的操作权限 */
	size_t shm_segsz;			/* 共享内存的大小,单位是字节 */
	__time_t shm_atime;			/* 对这段内存最后一次调用 shmat 的时间 */
	__time_t shm_dtime;			/* 对这段内存最后一次调用 shmdt 的时间 */
	__time_t shm_ctime;			/* 对这段内存最后一次调用 shmctl 的时间 */
	__pid_t shm_cpid;			/* 创建者的 PID */
	__pid_t shm_lpid;			/* 最后一次执行 shmat 或 shmdt 操作的进程 PID */
	shmatt_t shm_nattach;		/* 关联到此共享内存的进程数量 */
	/* 省略填充字段 */
};

初始化时,shm_lpid、shm_nattach、shm_atime、shm_dtime 设置为 0,shm_ctime 设置为当前时间;

1.5.2 shmat 和 shmdt

关联/分离到进程的地址空间

void* shmat( int shm_id, const void* shm_addr, int shmflg );
int shmdt( const void* shm_addr );

shm_addr 指定将共享内存关联到进程的哪块空间地址;

  • shm_addr 为 NULL,由操作系统选择,推荐的做法;
  • shm_addr 非空,并且 SHM_RND 未设置,共享内存关联到 addr 指定地址处;
  • shm_addr 非空,并且设置了 SHM_RND ,被关联的地址是 [shm_addr - (shm_addr%SHMLBA)];

shmflg 还支持如下标志:

  • SHM_RDONLY;进程仅能读取共享内存中的内容;
  • SHM_REMAP;如果地址 shm_addr 已经被关联到一段共享内存上,重新关联;
  • SHM_EXEC;指定对共享内存段的执行权限;

shmat 成功返回被关联的地址,失败返回(void *) -1 并设置 errno;将 shm_nattach++,shm_lpid 设置为调用进程 PID,shm_atime 设置为当前时间;

shmdt 成功时返回 0,失败返回 -1 设置 errno;将 shm_nattach–,shm_lpid 设置为调用进程 PID,shm_dtime 设置为当前时间;

1.5.3 shmctl
// 失败时返回 -1 设置 errno
int shmctl( int shm_id, int command, struct shmid_ds* buf );
命令含义成功时返回值
SETVAL将信号量的值设为 semun.val ,同时内核数据中的 semid_ds.sem_ctime 被更新0
1.5.4 共享内存的 POSIX 方法

通过打开同一个文件, mmap 可以实现进程间的内存共享;
Linux 提高了另一种利用 mmap 在无关进程间共享内存的方式,无需任何文件的支持;

#include <sys/mman.h>
#include <sys/stat.h>
#include <fcntl.h>
// 创建或打开一个 POSIX 共享内存对象
int shm_open( const char* name, int oflag, mode_t mode );
int shm_unlink( const char* name );

shm_open 成功返回一个文件描述符,该 fd 可用于后续的 mmap 调用,失败返回 -1 设置 errno。
shm_unlink 将 name 指定共享内存对象标记为等待删除;当所有使用该共享对象的进程都使用 ummap将它从进程中分离后,系统将销毁该对象;

ftruncate(fd, length)会将参数 fd 指定的文件大小改为参数 length 指定的大小。

1.6 消息队列

两个进程间传递二进制块数据一种简单有效的方式;
每个数据块都有一个特定的类型,接收方可以根据类型来选择地接收数据;

1.6.1 msgget
#include <sys/msg.h>
int msgget( key_t key, int msgflg );

参数含义与 semget一致,与之关联的内核数据结构 msqid_ds 被创建并初始化;

struct msqid_ds
{
	struct ipc_perm msg_perm;		/* 操作权限 */
	time_t msg_stime;				/* 最后一次调用 msgsnd 的时间 */
	time_t msg_stime;				/* 最后一次调用 msgrcv 的时间 */
	time_t msg_stime;				/* 最后一次被修改的时间 */
	unsigned long __msg_cbytes;		/* 消息队列中已有的字节数 */
	msgqnum_t msg_qnum;				/* 消息队列中已有的消息数 */
	msglen_t msg_qbytes;			/* 消息队列允许的最大字节数 */
	pid_t msg_lspid;				/* 最后执行 msgsnd 的进程 PID */
	pid_t msg_lrpid;				/* 最后执行 msgrcv 的进程 PID */
};

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

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

相关文章

【基于激光雷达的路沿检测用于自动驾驶的真值标注】

文章目录 概要主要贡献内容概述实验小结 概要 论文地址&#xff1a;https://arxiv.org/pdf/2312.00534.pdf 路沿检测在自动驾驶中扮演着重要的角色&#xff0c;因为它能够帮助车辆感知道可行驶区域和不可行驶区域。为了开发和验证自动驾驶功能&#xff0c;标注的数据是必不可…

LeetCode394.字符串解码

这道题有点像我之前写过的一道题有效的括号&#xff08;不只是栈&#xff09;-CSDN博客 但是比那道题要难&#xff0c;但用的方法是一样的&#xff0c;就是用栈的先进后出进行括号匹配&#xff0c;所以有写过之前那道题&#xff0c;这道题按照这个思路走我就写出了如下屎山代码…

智能算力进阶C位,揭秘人工智能产业背后的“冰山一角”

作者 | 曾响铃 文 | 响铃说 前几年&#xff0c;在IDC领域&#xff0c;市场谈及最多的还是数据中心&#xff0c;随着人工智能产业的成熟&#xff0c;特别是今年以来大模型的爆发&#xff0c;智算中心逐步替代了数据中心进入大众视野&#xff0c;成为市场热议的关键词&#xff…

【CMake保姆级教程】定义变量、指定C++标准、指定输出路径

文章目录 前言一、变量1.1 为什么需要变量&#xff1f;1.2 set的使用1.3 使用变量 二、指定C标准2.1 为什么需要指定C标准&#xff1f;2.2 指定使用的C标准 三、指定输出路径3.1 为什么需要指定输出路径&#xff1f;3.2 设置输出路径 总结 前言 CMake是一个强大的构建工具&…

WinRAR如何设置和清除密码?

WinRAR是一款功能强大的压缩管理器&#xff0c;除了能把文件打包变小&#xff0c;还能给压缩包设置密码保护&#xff0c;让文件不能随意打开&#xff0c;不需要时还可以把密码取消。下面来说说具体怎么操作吧。 WinRAR根据需要可以设置单次密码和永久密码&#xff0c;我们分别…

信息收集 - 谷歌hack

搜索引擎 FOFA网络空间测绘:https://fofa.info/ FOFA(FOcus on Assets)是一个网络空间搜索引擎,可以帮助用户快速定位和收集特定目标的信息。 ZoomEye:https://www.zoomeye.org ZoomEye 是一个网络空间搜索引擎,可以用于发现和收集特定目标的网络设备、Web应用程序、开放…

服务器加装了14T硬盘,显示不出来,戴尔R730阵列卡配置阵列RAID0

戴尔H730阵列卡配置阵列RAID0,1,5,10_哔哩哔哩_bilibili 然后依据下面的视频进行操作&#xff0c;ctrlr&#xff0c;选raid0 戴尔H730阵列卡配置阵列RAID0,1,5,10_哔哩哔哩_bilibili

Text2SQL学习整理(五)将Text-to-SQL任务与基本语言模型结合

导语 上篇博客&#xff1a;Text2SQL学习整理&#xff08;四&#xff09;将预训练语言模型引入WikiSQL任务简要介绍了两个借助预训练语言模型BERT来解决WIkiSQL数据集挑战的方法&#xff1a;SQLOVA和X-SQL模型。其中&#xff0c;借助预训练语言模型的强大表示能力&#xff0c;S…

vue3 element-plus 输入框 clearable属性 聚焦时宽度会变化

解决办法 因为你的代码中el-input是没有宽度的&#xff0c; 所以实际渲染出来的 el-input宽度 原生input宽度 前缀图标宽度 后缀图标宽度。 可以写css固定el-input宽度来处理。 :deep.el-input.el-input--default.el-input--suffix {// 固定宽度width: 200px !important; …

3年程序员开娱乐直播

今年就快结束了&#xff0c;愿你的梦想在2024年绽放&#xff0c;每一个努力都让你更接近自己的目标。 上海3年程序员&#xff0c;第一篇关于自己的博客&#xff0c;今天终于上手写了。 今年的大环境相信大家都很清楚了&#xff0c;降本增效这个一词弥漫在耳语之间&#xff0c;…

【ICCV2023】MMVP:基于运动矩阵的视频预测

目录 导读 本文方法 步骤1&#xff1a;空间特征提取 步骤2&#xff1a;运动矩阵的构造和预测 步骤3&#xff1a;未来帧的合成和解码 实验 实验结果 消融实验 结论 论文链接&#xff1a;https://openaccess.thecvf.com/content/ICCV2023/html/Zhong_MMVP_Motion-Matrix…

旅游海报图怎么做二维码展示?扫码即可查看图片

现在旅游攻略的海报可以做成二维码印刷在宣传单单页或者分享给用户来了解目的地的实际情况&#xff0c;出行路线、宣传海报等。用户只需要扫描二维码就可以查看内容&#xff0c;更加的方便省劲&#xff0c;那么旅游海报的图片二维码制作的技巧有哪些呢&#xff1f;使用图片二维…

白盒测试(超详细整理)

白盒测试 白盒测试&#xff08;White Box Testing&#xff09;又称结构测试、透明盒测试、逻辑驱动测试或基于代码的测试。白盒测试只测试软件产品的内部结构和处理过程&#xff0c;而不测试软件产品的功能&#xff0c;用于纠正软件系统在描述、表示和规格上的错误&#xff0c…

销量影响因素分析:从多维度解析商品市场表现

在商品市场中&#xff0c;销量是衡量一个商品或品牌成功与否的关键指标。然而&#xff0c;销量的影响因素众多&#xff0c;包括产品品质、价格、品牌知名度、营销策略、竞争环境等。为了深入了解商品市场的表现&#xff0c;我们需要从多个维度对销量影响因素进行分析。本文将通…

群多多社群人脉H5-2.1.4多开插件+小程序独立前端+搭建教程

功能介绍&#xff1a; 1、群多多社群大全&#xff0c;是一个集发布、展示社群信息、人脉推广的裂变工具/平台。 2、通过人脉广场&#xff0c;将商家信息通过名片进行展示&#xff0c;让资源对接、人脉推广更加便捷高效。 3、行业群、兴趣群、知识付费群、交友群、商家活动推…

OPC UA 与PROFINET比较

ROFINET和OPC UA是两种常见的协议&#xff0c;过去这两个协议有两个不同的角色。PROFINET通常用于现场设备和本地控制器之间的实时数据通信。而OPC UA通常用于在本地控制器和更高级别的MES和SCADA系统之间进行通信。 OPC UA 网络架构 PROFINET网络由IO控制器和IO设备组成&…

企业出海-如何保护客户账户安全?

近年来国内企业竞争日益激烈&#xff0c;许多企业在这般环境下难以持续发展。那么该如何获得业务的可持续性增长&#xff0c;如何获取更多的客户的同时开阔公司的视野&#xff1f;出海便是如今帮助国内企业能快速发展壮大的潮流之一&#xff0c;摆脱了局限于国内发展的束缚奔向…

FasterRCNN目标检测

R-CNN 四个步骤: 对输入图片提取候选区&#xff08;region proposal&#xff09;&#xff0c;每张大约2000个。论文中采用selective search的方法。对每个候选区采用CNN网络提取特征。此处需要将proposal的尺寸缩放成统一的227x227&#xff0c;以匹配CNN网络。最终提取到的特征…

基于ssm高校勤工助学系统论文

摘 要 传统办法管理信息首先需要花费的时间比较多&#xff0c;其次数据出错率比较高&#xff0c;而且对错误的数据进行更改也比较困难&#xff0c;最后&#xff0c;检索数据费事费力。因此&#xff0c;在计算机上安装高校勤工助学系统软件来发挥其高效地信息处理的作用&#x…

YZ系列工具之YZ03:高版本Excel的自定义菜单

我给VBA下的定义&#xff1a;VBA是个人小型自动化处理的有效工具。利用好了&#xff0c;可以大大提高自己的工作效率&#xff0c;而且可以提高数据的准确度。我的教程一共九套一部VBA手册&#xff0c;教程分为初级、中级、高级三大部分。是对VBA的系统讲解&#xff0c;从简单的…