进程与线程（三）

进程与线程（三）

  • 进程间通信
  • 传统间的进程间通信机制
    • 无名管道
      • 无名管道的特征
      • 无名管道的创建
      • 父子进程通信
      • 测试管道的大小
      • 管道读写易出现的问题
    • 有名管道
      • 创建有名管道
      • 有名管道的写端代码
      • 有名管道的读端代码
    • 信号
      • 信号的特征
      • 产生信号
        • 硬件来源
        • 软件来源
          • 发送信号的函数：kill() raise()
          • 定时器信号
      • 响应信号
      • 信号安装：
        • 忽略信号
        • 执行缺省操作
        • 捕捉信号

进程间通信

在这里插入图片描述
常用的进程间通信方式
1、传统的进程间通信方式
无名管道(pipe)、有名管道(fifo)和信号(signal)
2、System V IPC对象
共享内存(share memory)、消息队列(message queue)和信号灯(semaphore)
3、BSD
套接字(socket)

传统间的进程间通信机制

无名管道

在这里插入图片描述

无名管道的特征

这里所说的管道主要指无名管道，它具有如下特点：
1、只能用于具有亲缘关系的进程之间的通信
2、半双工的通信模式，具有固定的读端和写端
3、管道可以看成是一种特殊的文件，对于它的读写可以使用文件IO如read、write函数。

在这里插入图片描述

无名管道的创建

在这里插入图片描述

父子进程通信

（1）创建无名管道
（2）创建子进程
（3）完成父子通信业务
通信流程：子进程发消息给父进程
思路：fd[0]读端 fd[1]写端 ----》固定的
子进程：发消息（fd[1]有效） fd[0]关闭掉
父进程：收消息（fd[0]有效） fd[1]关闭掉

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <string.h>
int main(int argc, const char *argv[])
{//1，创建无名管道//定义数组，存储读写的文件描述符int fd[2];if(pipe(fd) < 0){perror("pipe error");return -1;}printf("pipe ok!\n");//2，创建子进程pid_t pid = fork();if(pid < 0){perror("fork error");close(fd[0]);close(fd[1]);return -1;}else if(0 == pid){//子进程的地址空间//关闭读端close(fd[0]);//发消息（write）//定义消息文本char Message[100] = {0};printf("请输入需要发送的消息:");fgets(Message, sizeof(Message), stdin);//使用write写入到管道中write(fd[1], Message, strlen(Message));printf("send ok!\n");}else{//父进程的地址空间//关闭写端close(fd[1]);//收消息（read）//定义接收消息的地址空间char Message[100] = {0};read(fd[0], Message, sizeof(Message));printf("来自于子进程:%s\n",Message);}return 0;
}

在这里插入图片描述

测试管道的大小

思路：往管道中不管写入，直到写不进去，此时写入的字节数就是管道容量大小

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <string.h>
int main()
{//测试管道大小//创建管道int fd[2];if(pipe(fd) < 0){return -1;}printf("create pipe ok!\n");//写入数据，不断写入//1KB == 1024bytechar buf[1024] = {0};int size = 0;while(1){int wr_count = write(fd[1], buf, 1024);//每次写入1024个字节 即：1KB大小if(wr_count < 0){perror("write error");break;}else if(0 == wr_count){printf("nothing wai be written...\n");break;}else{size++;printf("%dKB\n",size);}}close(fd[0]);close(fd[1]);return 0;
}

在这里插入图片描述

管道读写易出现的问题

当管道中无数据时，读操作会阻塞
向管道中写入数据时，linux将不保证写入的原子性，管道缓冲区一有空闲区域，写进程就会试图向管道写入数据。如果读进程不读走管道缓冲区中的数据，那么写操作将会一直阻塞。
只有在管道的读端存在时，向管道中写入数据才有意义。否则，向管道中写入数据的进程将收到内核传来的SIGPIPE信号(通常Broken pipe错误)。

在这里插入图片描述
在这里插入图片描述

案例：验证管道断裂

#include <stdio.h>
#include <sys/types.h>
#inckude <unistd.h>
#include <string.h>
int main()
{int fd[2];if(pipe(fd) < 0){return -1;}printf("pipe ok!\n");//关闭读端 （保证写入管道时，读端不存在---》才会出现管道断裂）close(fd[0]);pid_t pid = fork();if(pid < 0){return -1;}else if(0 == pid){//子进程//写入数据到管道char data[1024];printf("Please input:");fgets(data, sizeof(data), stdin);write(fd[1], data, strlen(data));printf("写入管道成功!\n");exit(100);}else{//父进程//使用wait阻塞等待子进程退出时回收其资源int wstatus;//保存子进程的退出状态值wait(&wstatus);//当执行该40行时，说明子进程已经退出（收到信号异常退出还是正常执行exit(100)退出？）//分类讨论if(WIFSIGNALED(wstatus)){//收到信号导致子进程退出printf("导致子进程退出的信号是:%d\n",WTERMSIG(wstatus));//SIGPIPE==13号}else if(WIFEXITED(wstatus)){//正常退出---》执行了exit(100)printf("子进程的退出状态数值为:%d\n",WEXITSTATUS(wstatus));//父进程char buf[1024] = {0};read(fd[0], buf, sizeof(buf));printf("读取的结果是:%s\n",buf);}}return 0;
}

有名管道

无名管道只能用于具有亲缘关系的进程之间，这就限制了无名管道的使用范围
1、有名管道可以使互不相关的两个进程互相通信。
2、有名管道可以通过路径名来指出，并且在文件系统中可见
3、进程通过文件IO来操作有名管道
4、有名管道遵循先进先出规则，不支持如lseek() 操作

在这里插入图片描述

创建有名管道

在这里插入图片描述
在这里插入图片描述

有名管道的写端代码

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
int main(int argc, const char *argv[])
{//创建有名管道(同时也创建好了管道文件)if(mkfifo("./fifo.txt", 0664) < 0 && errno != EEXIST){perror("mkfifo error");return -1;}printf("mkfifo ok!\n");//以只写方式打开创建好的管道文件int fw = open("./fifo.txt", O_WRONLY);if(fw < 0){perror("open_write error");return -1;}printf("open_write ok!\n");char buf[1024] = {0};while(1){//对于buf做清空bzero(buf, sizeof(buf));printf("客户端:");fgets(buf, sizeof(buf), stdin);//判断客户端是否办理完毕业务if(0 == strncasecmp("quit", buf, 4)){printf("业务办理结束!\n");break;}//发送消息int wr_count = write(fw, buf, strlen(buf));if(wr_count < 0){perror("write error");break;}else if(0 == wr_count){printf("未写入任何内容...\n");break;}else{printf("实际发送%d字节内容!\n",wr_count);printf("send ok!\n");}}//关闭写端close(fw);return 0;
}

有名管道的读端代码

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
int main(int argc, const char *argv[])
{//创建有名管道(同时也创建好了管道文件)if(mkfifo("./fifo.txt", 0664) < 0 && errno != EEXIST){perror("mkfifo error");return -1;}printf("mkfifo ok!\n");//以只读方式打开创建好的管道文件int fr = open("./fifo.txt", O_RDONLY);if(fr < 0){perror("open_read error");return -1;}printf("open_read ok!\n");char buf[1024] = {0};while(1){//对于buf做清空bzero(buf, sizeof(buf));//接收消息int rd_count = read(fr, buf, sizeof(buf));if(rd_count < 0){perror("read error");break;}else if(0 == rd_count){printf("客户端业务处理结束!\n");break;}else{printf("成功接收%d个字节!\n",rd_count);printf("来自于客户端:%s\n",buf);}}close(fr);return 0;
}

在这里插入图片描述

信号

信号的特征

信号是在软件层次上对中断机制的一种模拟，是一种异步通信方式
信号可以直接进行用户空间进程和内核进程之间的交互，内核进程也可以利用它来通知用户空间进程发生了哪些系统事件。
如果该进程当前并未处于执行态，则该信号就由内核保存起来，直到该进程恢复执行再传递给它；如果一个信号被进程设置为阻塞，则该信号的传递被延迟，直到其阻塞被取消时才被传递给进程
同步:发送方发送数据,等待接收方响应之后才发下一个数据包的通讯方式
异步:发送方发送数据,不等待接收方发回响应,接着发送下一个数据包的通讯方式

产生信号

硬件来源

从键盘输入：
ctrl c : SIGINT信号 ，默认处理方式为进程终止
ctrl : SIGQUIT信号，作用与SIGINT类似，默认处理方式为进程终止
ctrl z: SIGTSTP信号，默认处理方式为进程暂停
SIGSTOP信号：只能通过kill产生，默认处理方式进程暂停

软件来源
发送信号的函数：kill() raise()

#include <sys/types.h>
#include <signal.h>
int kill(pid_t pid, int sig);
功能：不仅可以终止进程,也可以向进程发送其他信号
#include <signal.h>
int raise(int sig);
功能：只允许进程向自身发送信号

案例：首先使用fork创建子进程,在子进程中使用raise()向自身发送SIGSTOP信号,使子进程暂停；接下来在父进程中当时间戳超过10秒之后，调用kill()向子进程发送SIGKILL信号杀死子进程并回收子进程的退出
资源，且检查导致子进程退出是否因为收到了信号，如果是，打印出该信号是几号？如果子进程是正常退出，则打印出子进程退出的状态值是多少？（模拟正常退出：例如在终端给子进程发送SIGCONT信号来唤醒子进程，此时子进程继续执行，直到执行了exit()退出）

#include <stdio.h>
#include <sys/types.h>
#include <signal.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <sys/wait.h>
int main(int argc, const char *argv[])
{//功能：练习kill()和raise()pid_t pid = fork();if(0 == pid){//子进程printf("child PID = %d\tparent PID = %d\n", \getpid(), getppid());//使用raise()函数给子进程自己发送SIGSTOP,让其暂停raise(SIGSTOP);printf("I am wakeup...\n");printf("hahahah\n");exit(88);}else{//父进程//定义保存时间的变量time_t start_time, current_time;time(&start_time);int wstatus;//回收子进程退出资源while(1){//获取当前的系统时间（更新的）time(&current_time);if(current_time - start_time > 10){//使用kill()函数给子进程发送SIGKILL信号，让其终止kill(pid, SIGKILL);}int exitID = waitpid(-1, &wstatus, WNOHANG);if(exitID < 0){perror("waitpid error");break;}else if(0 == exitID){printf("子进程还未结束...\n");}else{//已成功回收子进程printf("已成功回收子进程的退出资源...\n");if(WIFSIGNALED(wstatus)){printf("异常退出，造成子进程退出的信号是:%d号信号!\n",WTERMSIG(wstatus));}else if(WIFEXITED(wstatus)){printf("子进程正常退出，退出状态数值为:%d\n",WEXITSTATUS(wstatus));}break;}//每隔1秒 轮询一次sleep(1);}}return 0;
}

在这里插入图片描述

定时器信号

#include <unistd.h>
unsigned int alarm(unsigned int seconds);
参数：秒数
当定时器指定的时间到了时，它就向进程发送SIGALARM信号，信号的默认操作是结束进程.
注意：每个进程只能有一个闹钟时间。如果在调用alarm时，以前已为该进程设置过闹钟时间，而且它还没有超时，则该闹钟时间的剩余时间值作为本次alarm函数调用的值返回，以前登记的闹钟时间则被新值代换。如果有以前登记的尚未超过的闹钟时间，而新设的闹钟时间值为0，则取消以前的闹钟时间，其剩余时间值仍作为函数的返回值。
扩充：将调用进程挂起函数：
#include <unistd.h>
int pause(void);
功能：会造成进程主动挂起(处于阻塞状态，并主动放弃CPU)，并且等待信号将其唤醒

案例：使用alarm()和pause()函数

#include <stdio.h>
#include <unistd.h>
int main(int argc, const char *argv[])
{printf("hello!\n");//设定闹钟 5秒alarm(5);printf("I will.....\n");//进程挂起pause();printf("java!\n");printf("exit!\n");return 0;
}

在这里插入图片描述

响应信号

在这里插入图片描述
在这里插入图片描述

信号安装：

signal函数原型：
#include <signal.h>
void (*signal(int signum, void (*handler)(int)))(int);
优化原型：看的更清楚。
//给函数指针类型取别名
#include <signal.h>
typedef void (*sighandler_t)(int);
sighandler_t signal(int signum, sighandler_t handler);
功能：进行信号安装
参数：
参数1：需要安装的信号名称
参数2：对于该信号的处理函数（该函数是用户自定义的，且返回值类型void ,形参是一个
int的函数的地址）
PS：参数2的位置可以传入：忽略（SIG_IGN） 执行缺省操作（SIG_DFL）,信号处理函数的地址
返回值：成功安装完毕的信号处理函数的地址。

信号的处理方式可以有：
1、忽略信号
2、执行缺省操作（默认操作）
3、捕捉信号（自定义信号处理函数）

忽略信号
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
int main(int argc, const char *argv[])
{//安装信号signal(SIGINT, SIG_IGN);//忽略信号//执行一段代码while(1){printf("hello!\n");sleep(1);}return 0;
}

在这里插入图片描述

执行缺省操作
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
int main(int argc, const char *argv[])
{//安装信号//signal(SIGINT, SIG_IGN);//忽略信号signal(SIGINT, SIG_DFL);//缺省操作（信号默认处理方式）//执行一段代码while(1){printf("hello!\n");sleep(1);}return 0;
}

在这里插入图片描述

捕捉信号
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
void handler_func(int signum)
{printf("不处理哦!\n");
}
int main(int argc, const char *argv[])
{//安装信号//signal(SIGINT, SIG_IGN);//忽略信号//signal(SIGINT, SIG_DFL);//缺省操作（信号默认处理方式）signal(SIGINT, &handler_func);//执行一段代码vwhile(1){printf("hello!\n");sleep(1);}return 0;
}

在这里插入图片描述
注意：一个信号处理函数响应多个信号

#include <stdio.h>
#include <signal.h>
#include <unistd.h>
void handler_func(int signum)
{//按照信号的类别进行控制switch(signum){case SIGINT:{printf("paly music...\n");break;}case SIGTSTP:{printf("paly vedio...\n");break;}case SIGQUIT:{printf("quit...\n");break;}default:{printf("信号无法响应...\n");}}return;
}
int main(int argc, const char *argv[])
{//安装信号//signal(SIGINT, SIG_IGN);//忽略信号//signal(SIGINT, SIG_DFL);//缺省操作（信号默认处理方式）//signal(SIGINT, &handler_func);//捕捉信号--》自定义信号处理函数//安装3个信号signal(SIGINT, &handler_func);//播放音乐signal(SIGTSTP, &handler_func);//播放视频signal(SIGQUIT, &handler_func);//退出app//执行一段代码while(1){printf("hello!\n");sleep(1);}return 0;
}

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Linux chmod 命令

Linux chmod 命令

Linux chmod 命令 在 Linux 操作系统中&#xff0c;chmod 命令是非常重要的。它可以用于修改文件和目录的访问权限&#xff0c;以及控制用户对系统资源的访问。在这篇博客中&#xff0c;我们将深入探讨 chmod 命令的使用方法&#xff0c;以及如何使用它来管理文件和目录的访问…
阅读更多...
什么是主码，什么是候选码，主码的候选码的区别是什么

什么是主码，什么是候选码，主码的候选码的区别是什么

目录 一、候选码 (Candidate Key) 1.定义 2.特点 二、主码 (Primary Key) 1.定义 2.特点 三、关系和区别 1.关系 2.区别 一、候选码 (Candidate Key) 1.定义 候选码是能够唯一标识数据库表中每一条记录的属性集合。一个表可以有一个或多个候选码。 2.特点 每个候选…
阅读更多...
【U-Boot 源码深度解析】000 - 文章链接汇总

【U-Boot 源码深度解析】000 - 文章链接汇总

【U-Boot 源码深度解析】000 - 文章链接汇总 下载链接 https://ftp.denx.de/pub/u-boot/ 《【U-Boot 源码深度解析】001 - Ubuntu 24.04 虚拟机 及 基础环境搭建》
阅读更多...
ORACLE RAC的一些基本理论知识

ORACLE RAC的一些基本理论知识

一 . Oracle RAC 的发展历程 1. Oracle Parallel Server (OPS) 早期阶段&#xff1a;Oracle 6 和 7 Oracle Parallel Server&#xff08;OPS&#xff09;是 Oracle RAC 的前身。 通过多个实例并行访问同一个数据库来提高性能。 共享磁盘架构&#xff0c;利用分布式锁管理&am…
阅读更多...
JZ2440笔记：Nor FLASH驱动程序

JZ2440笔记：Nor FLASH驱动程序

(1)测试原有的驱动&#xff1a; make menuconfig修改physmap-flash驱动配置&#xff1a;起始0&#xff0c;大小0x100000&#xff0c;位宽2&#xff0c;make modules后拷贝过去测试&#xff1a; # insmod physmap.ko physmap platform flash device: 01000000 at 00000000 phy…
阅读更多...
C#面：解释什么是viewstate，能否禁用？是否所用控件都可以禁用

C#面：解释什么是viewstate，能否禁用？是否所用控件都可以禁用

在C#中&#xff0c;ViewState是 ASP.NET Web Forms中的一个重要概念。它用于在Web应用程序中跨页面请求之间保存和恢复页面的状态数据。ViewState的主要目的是在页面回发&#xff08;postback&#xff09;期间保持页面上的控件状态&#xff0c;以便在页面重新加载后能够正确地还…
阅读更多...
addEventListener()方法中的几个参数，以及作用

addEventListener()方法中的几个参数，以及作用

addEventListener() 方法是 JavaScript 中用于处理指定元素的指定事件的函数。它有三个参数&#xff1a; type&#xff08;必需&#xff09;&#xff1a;一个字符串&#xff0c;指定要监听的事件名。 listener&#xff08;必需&#xff09;&#xff1a;一个实现了 EventListen…
阅读更多...
【第1章】SpringBoot实战篇之注册接口

【第1章】SpringBoot实战篇之注册接口

文章目录 前言一、代码部分1. User2.UserMapper13. UserSerivce4. UserController15. Result 二、测试1.注册2.再次注册 总结 前言 下面介绍用户注册接口。 一、代码部分 1. User package org.example.springboot3.bigevent.entity;import com.baomidou.mybatisplus.annotat…
阅读更多...
开发板uboot与virtualbox虚拟机、windows11网络互通

开发板uboot与virtualbox虚拟机、windows11网络互通

环境&#xff1a;virtualbox中ubuntu22.04.4&#xff0c;开发板通过网线再经过拓展坞usb网卡跟windows11连接。连接如下&#xff1a; 1、关闭windows防火墙(重要) 2、先在VirtualBox的工具选项创建两个网络【仅主机(Host-Only)网络】和【NAT网络】 仅主机(Host-Only)网络的ip:…
阅读更多...
Linux下Qt Creator无法输入中文（已解决）

Linux下Qt Creator无法输入中文（已解决）

1. 首先确保安装了搜狗输入法&#xff0c;且能正常运行。 2.克隆源码到本地。 git clone https://gitcode.com/fcitx/fcitx-qt5.git 3.检查Qt Creator版本&#xff0c;如下图所示&#xff0c;为基于Qt6的。 4. 进入源码目录&#xff0c;建立build文件夹&#xff0c;修改CMak…
阅读更多...
并发任务的进化之旅

并发任务的进化之旅

An evolutionary journey of multitasking 多重任务的进化之旅 In the beginning, computers had one CPU that executed a set of instructions written by a programmer one by one. No operating system (OS), no scheduling, no threads, no multitasking. This was how …
阅读更多...
js实现基础购物车的制作

js实现基础购物车的制作

功能需求&#xff1a; 1.点击添加商品按钮会出现三个输入框&#xff08;名称&#xff0c;价格&#xff0c;数量那三格&#xff0c;以及确认和取消按钮&#xff09;。 2.点击确认后所输入的值会自动形成一行添加到表格中 3.点击编辑按钮时&#xff0…
阅读更多...
css动态导航栏鼠标悬停特效

css动态导航栏鼠标悬停特效

charset "utf-8"; /*科e互联特效基本框架CSS*/ body, ul, dl, dd, dt, ol, li, p, h1, h2, h3, h4, h5, h6, textarea, form, select, fieldset, table, td, div, input {margin:0;padding:0;-webkit-text-size-adjust: none} h1, h2, h3, h4, h5, h6{font-size:12px…
阅读更多...
8、资源操作 Resource

8、资源操作 Resource

目录 8.1、Spring Resources概述补充&#xff1a;什么是 low-level 资源&#xff1f;1. 文件系统资源2. 类路径资源3. URL资源4. 内嵌资源5. InputStream资源6. ServletContext资源示例代码结论 8.2、Resource接口8.3、Resource的实现类8.3.1、UrlResource访问网络资源1&#x…
阅读更多...
LIO-EKF: 运行数据UrbanNav与mid360设备详细教程

LIO-EKF: 运行数据UrbanNav与mid360设备详细教程

一、代码连接 代码下载连接&#xff1a; YibinWu/LIO-EKF: Maybe the simplest LiDAR-inertial odometry that one can have. (github.com) 编译步骤&#xff1a; cd srcgit clone gitgithub.com:YibinWu/LIO-EKF.gitcatkin_makesource devel/setup.bash 运行步骤&#xff1a; …
阅读更多...
为什么要保持方差为1

为什么要保持方差为1

1.数值稳定性&#xff1a; 在机器学习和深度学习中&#xff0c;维持激活函数输入的方差在一个合理范围内&#xff08;如1&#xff09;是很重要的&#xff0c;这有助于防止在训练过程中发生梯度消失或梯度爆炸的问题。如果方差过大或过小&#xff0c;经过多层网络后输出结果的方…
阅读更多...
java并发处理机制

java并发处理机制

在Java中&#xff0c;并发处理机制主要是通过线程来实现的。Java提供了丰富的类和接口来支持多线程编程&#xff0c;主要集中在 java.util.concurrent 包中。以下是一些关键的并发处理机制&#xff1a; 1.线程创建&#xff1a;可以通过继承 Thread 类或实现 Runnable 接口来创建…
阅读更多...
公园【百度之星】/图论+dijkstra

公园【百度之星】/图论+dijkstra

公园 图论dijkstra #include<bits/stdc.h> using namespace std; typedef long long ll; typedef pair<ll,ll> pii; vector<ll> v[40005]; //a、b、c分别是小度、度度熊、终点到各个点的最短距离 ll a[40005],b[40005],c[40005],dist[40005],st[40005]; void…
阅读更多...
原码、反码和真值都不存在！

原码、反码和真值都不存在！

文章目录 补码的理解十进制计算二进制计算 补码和真值换算数制转换负数补码转真值负数真值转补码 注&#xff1a;均来自 做而论道 答主的理解。 补码的理解 在计算机系统中&#xff0c;根本就没有原码和反码&#xff0c;真值也是不存在的。在计算机系统中&#xff0c;并不使用…
阅读更多...
java 远程调试

java 远程调试

1.远程启动时 jdk1.8-32\jre\bin\java.exe -Dfile.encodingUTF-8 -Djava.library.pathlib -agentlib:jdwptransportdt_socket,servery,suspendn,address5005 -jar local-com.yuetai.service-0.0.1-SNAPSHOT.jar --spring.config.locationapplication.yml 2.本地调试项目连接远…
阅读更多...
最新文章

Copyright @ 2022~2023