【并发程序设计】11.进程间通信

2024-05-29 11:12
文章标签 设计 间通信 进程 并发程序

本文主要是介绍【并发程序设计】11.进程间通信，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

11.进程间通信

（IPC，InterProcess Communication）进程和进程之间交换信息。

  • 常用通信方式
    • 无名管道（pipe）
    • 有名管道 （fifo）
    • 信号（signal）
    • 共享内存(mmap)
    • 套接字（socket）
  • 过时的IPC通信方式
    • System V IPC
    • 共享内存（share memory）
    • 消息队列（message queue）
    • 信号灯集（semaphore set）

无名管道

无名管道（也称为匿名管道）是UNIX和类UNIX系统下进程间通信的一种机制：

​ 数据读取完后自动删除不会留存

  1. 半双工通信：数据只能在管道的一个方向上流动，具有固定的读端和写端。这意味着在一个时间点上，数据只能在一个方向上被传输，无法同时进行双向通信。
  2. 亲缘关系进程间通信：无名管道通常用于具有亲缘关系的进程之间，如父子进程或兄弟进程之间的通信。一个进程创建管道后，可以通过fork()创建子进程，然后父子进程可以通过这个管道进行数据交换。
  3. 特殊文件形式：无名管道可以看作是一种特殊的文件，对于它的读写可以使用普通的read、write等函数。但它并不属于任何文件系统，不支持如lseek()操作，且只存在于内存中。

读写特性

  • 读管道：
    • 管道中有数据
      • read返回实际读到的字节数。
    • 管道中无数据：
      • 管道写端被全部关闭，read返回0 (好像读到文件结尾)
      • 写端没有全部被关闭，read阻塞等待(不久的将来可能有数据递达，此时会让出cpu
  • 写管道：
    • 管道读端全部被关闭
      • 进程异常终止(也可使用捕捉SIGPIPE信号，使进程不终止)
    • 管道读端没有全部关闭
      • 管道已满，write阻塞。（管道大小64K）
      • 管道未满，write将数据写入，并返回实际写入的字节数。

pipe函数

  1. 原型：

    #include <unistd.h>
int pipe(int pipefd[2]);

  2. 功能：pipe函数创建一个管道，用于在两个文件描述符之间进行单向数据传输。一个文件描述符用于读操作，另一个用于写操作。

  3. 参数：

    • int pipefd[2]: 一个包含两个整数的数组。

      • pipefd[0]是管道的读端，

      • pipefd[1]是管道的写端。

  4. 返回值：

    • 成功时，返回0，并在pipefd中设置两个文件描述符。
    • 失败时，返回-1，并设置errno以指示错误类型。

  5. 注意：

    • 只能用于亲缘关系的进程间通信（父子进程，兄弟进程）
    • 管道通信是单工的，一端读，一端写（程序实现设计好）。
    • 数据自己读不能自己写
    • 管道可以用于大于2个进程共享

示例

：一个父进程写，三个子进程读

#include <stdio.h>
#include <unistd.h>
#include <string.h>
int main(){int pfd1[2];//文件描述符int re,i;char buf1[20]={0};char buf2[20]={0};pid_t pid;//创建无名管道re = pipe(pfd1);if(re<0){perror("pipe");return 0;}//创建三个子进程for(i=0; i<3; i++){pid = fork();//创建子进程if(pid<0){perror("fork");return 0;}else if(pid == 0)//如果是子进程就退出循环break;}if(i==3)//父进程{//close(pfd1[0]);while(1){strcpy(buf1,"hello world");write(pfd1[1],buf1,strlen(buf1));//写入管道sleep(1);}}else if(i==0)//子进程0{//close(pfd1[1]);        while(1){re=read(pfd1[0],buf2,20);//读取管道数据if(re>0){printf("0read pfd=%s\n",buf2);}    }}else if(i==1)//子进程1{//close(pfd1[1]);        while(1){re=read(pfd1[0],buf2,20);//读取管道数据if(re>0){printf("1read pfd=%s\n",buf2);}    }}else if(i==2)//子进程2{//close(pfd1[1]);        while(1){re=read(pfd1[0],buf2,20);//读取管道数据if(re>0){printf("2read pfd=%s\n",buf2);}    }}
}

在这里插入图片描述

有名管道（命名管道）

有名管道，也称为命名管道或FIFO（First In First Out），是一种特殊类型的管道，它允许不相关的进程通过文件系统进行通信。与无名管道相比，有名管道的一个显著特点是提供了一个路径名与之关联，从而可以在任意两个进程之间进行通信。

​ 数据读取完后自动删除不会留存

以下是有名管道的读写特性：

  • 引用计数影响：当所有指向管道写端的文件描述符都关闭时（即写端引用计数为0），如果有进程尝试从读端读取数据，那么管道中剩余的数据被读取后，再次尝试读取会返回0，类似于读到文件末尾的情况。如果写端的引用计数大于0，即仍有文件描述符指向写端且没有写入数据，那么读端在读取完剩余数据后，再次读取会阻塞，直到有新的数据写入。
  • 信号通知：当所有指向管道读端的文件描述符都关闭时（即读端引用计数为0），如果有进程试图向管道中写入数据，该进程会收到一个SIGPIPE信号，通常这会导致进程异常终止。
  • 特殊文件形式：有名管道在文件系统中以特殊文件的形式存在，这意味着它可以通过路径名被访问，并且可以由任何有相应权限的进程使用。这与无名管道只能在亲缘关系的进程间通信不同。
  • 半双工通信：尽管有名管道允许任意进程间通信，但它仍然是一种半双工通信方式，意味着数据只能在一个方向上流动，不能同时进行读写操作。

特点：

  1. 有名管道可以使非亲缘的两个进程互相通信

  2. 通过路径名来操作，在文件系统中可见，但内容存放在内存中

  3. 文件IO来操作有名管道

  4. 遵循先进先出规则

  5. 不支持leek操作

  6. 单工读写

mkfifo函数

  1. 原型：

    #include <sys/types.h>
#include <sys/stat.h>
int mkfifo(const char *pathname, mode_t mode);

  2. 功能：mkfifo函数创建一个命名管道（FIFO），该管道存在于文件系统中，可以用于不同进程之间的通信。

  3. 参数：

    • const char *pathname: 管道的路径名。指定创建的命名管道的路径和文件名。

    • mode_t mode: 指定文件的权限位，如读、写、执行权限。通常使用宏定义，例如 S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH 等。

  4. 返回值：

open函数

  1. 原型：

    #include <fcntl.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
int open(const char *pathname, int flags, ...);

  2. 功能：open函数用于打开一个文件，如果成功，则返回一个文件描述符，该文件描述符可用于后续的读写操作。

  3. 参数：

    • const char *pathname: 文件的路径名。指定要打开的文件路径。
    • int flags: 文件打开模式和标志位。常用的标志包括：
      • O_RDONLY: 只读模式
      • O_WRONLY: 只写模式
      • O_RDWR: 读写模式
      • O_CREAT: 如果文件不存在则创建文件
      • O_NONBLOCK（非阻塞）可以用|与其他模式连接，不加这个选项表示阻塞
      • O_EXCL: 与 O_CREAT 一起使用，如果文件已存在则返回错误
      • O_TRUNC: 如果文件存在且可写，则将其长度截断为0
      • O_APPEND: 每次写操作都会追加到文件的末尾
    • mode_t mode: 可选参数，仅在使用 O_CREAT 标志时需要。指定文件的权限位，例如 S_IRUSR（用户读权限）、S_IWUSR（用户写权限）、S_IRGRP（组读权限）等。

  4. 返回值：

    • 成功时，返回文件描述符。
    • 失败时，返回-1，并设置errno以指示错误类型。

注意事项

  1. 程序不能以O_RDWR(读写)模式打开FIFO文件进行读写操作，而其行为也未明确定义，因为如一个管道以读/写方式打开，进程可以读回自己的输出，同时我们通常使用FIFO只是为了单向的数据传递

  2. 第二个参数中的选项O_NONBLOCK，选项O_NONBLOCK表示非阻塞，加上这个选项后，表示open调用是非阻塞的，如果没有这个选项，则表示open调用是阻塞的

  3. **对于以只读方式（O_RDONLY）**打开的FIFO文件，如果open调用是阻塞的（即第二个参数为O_RDONLY），除非有一个进程以写方式打开同一个FIFO，否则它不会返回；如果open调用是非阻塞的的（即第二个参数为O_RDONLY | O_NONBLOCK），则即使没有其他进程以写方式打开同一个FIFO文件，open调用将成功并立即返回。

    对于以只写方式（O_WRONLY）打开的FIFO文件，如果open调用是阻塞的（即第二个参数为O_WRONLY），open调用将被阻塞，直到有一个进程以只读方式打开同一个FIFO文件为止；如果open调用是非阻塞的（即第二个参数为O_WRONLY | O_NONBLOCK），open总会立即返回，但如果没有其他进程以只读方式打开同一个FIFO文件，open调用将返回-1，并且FIFO也不会被打开。

  4. 数据完整性,如果有多个进程写同一个管道，使用O_WRONLY方式打开管道，如果写入的数据长度小于等于PIPE_BUF（4K），那么或者写入全部字节，或者一个字节都不写入，系统就可以确保数据决不会交错在一起。

示例

：两个没有亲缘关系的进程通信

write.c

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
int main()
{int re;int fd;char buf[32];//创建管道文件re = mkfifo("/myfifo",0666);if(re<0){perror("mkfifo");return 0;}//打开管道文件fd = open("/myfifo",O_WRONLY|O_NONBLOCK);//只写非阻塞方式打开if(fd<0){perror("open");return 0;}printf("after open\n");//写入管道数据while(1){fgets(buf,32,stdin);//读取键盘输入write(fd,buf,strlen(buf));}
}

read.c

#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
int main()
{int re;int fd;char buf[32];fd = open("/myfifo",O_RDONLY);//只读阻塞方式打开管道文件if(fd<0){perror("open");return 0;}printf("after open\n");//读取管道数据while(1){     re=read(fd,buf,32);if(re>0)printf("read fifo=%s\n",buf);        else if(re==0)//exit(0);}
}

这篇关于【并发程序设计】11.进程间通信的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1013504。

相关文章

Linux中的进程间通信之匿名管道解读

Linux中的进程间通信之匿名管道解读

《Linux中的进程间通信之匿名管道解读》：本文主要介绍Linux中的进程间通信之匿名管道解读,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、基本概念二、管道1、温故知新2、实现方式3、匿名管道（一）管道中的四种情况（二）管道的特性总结一、基本概念我们知道多
阅读更多...
Linux进程终止的N种方式详解

Linux进程终止的N种方式详解

《Linux进程终止的N种方式详解》进程终止是操作系统中,进程的一个重要阶段,他标志着进程生命周期的结束,下面小编为大家整理了一些常见的Linux进程终止方式,大家可以根据需求选择... 目录前言一、进程终止的概念二、进程终止的场景三、进程终止的实现3.1 程序退出码3.2 运行完毕结果正常3.3 运行完毕
阅读更多...
Windows命令之tasklist命令用法详解(Windows查看进程)

Windows命令之tasklist命令用法详解(Windows查看进程)

《Windows命令之tasklist命令用法详解(Windows查看进程)》tasklist命令显示本地计算机或远程计算机上当前正在运行的进程列表,命令结合筛选器一起使用,可以按照我们的需求进行过滤... 目录命令帮助1、基本使用2、执行原理2.1、tasklist命令无法使用3、筛选器3.1、根据PID
阅读更多...
linux本机进程间通信之UDS详解

linux本机进程间通信之UDS详解

《linux本机进程间通信之UDS详解》文章介绍了Unix域套接字（UDS）的使用方法,这是一种在同一台主机上不同进程间通信的方式,UDS支持三种套接字类型：SOCK_STREAM、SOCK_DGRA... 目录基础概念本机进程间通信socket实现AF_INET数据收发示意图AF_Unix数据收发流程图A
阅读更多...
Python中多线程和多进程的基本用法详解

Python中多线程和多进程的基本用法详解

《Python中多线程和多进程的基本用法详解》这篇文章介绍了Python中多线程和多进程的相关知识,包括并发编程的优势,多线程和多进程的概念、适用场景、示例代码,线程池和进程池的使用,以及如何选择合适... 目录引言一、并发编程的主要优势二、python的多线程（Threading）1. 什么是多线程？2.
阅读更多...
linux进程D状态的解决思路分享

linux进程D状态的解决思路分享

《linux进程D状态的解决思路分享》在Linux系统中,进程在内核模式下等待I/O完成时会进入不间断睡眠状态（D状态）,这种状态下,进程无法通过普通方式被杀死,本文通过实验模拟了这种状态,并分析了如... 目录1. 问题描述2. 问题分析3. 实验模拟3.1 使用losetup创建一个卷作为pv的磁盘3.
阅读更多...
Linux环境变量&&进程地址空间详解

Linux环境变量&&进程地址空间详解

《Linux环境变量&&进程地址空间详解》本文介绍了Linux环境变量、命令行参数、进程地址空间以及Linux内核进程调度队列的相关知识,环境变量是系统运行环境的参数,命令行参数用于传递给程序的参数,... 目录一、初步认识环境变量1.1常见的环境变量1.2环境变量的基本概念二、命令行参数2.1通过命令编程
阅读更多...
Linux之进程状态&&进程优先级详解

Linux之进程状态&&进程优先级详解

《Linux之进程状态&&进程优先级详解》文章介绍了操作系统中进程的状态,包括运行状态、阻塞状态和挂起状态,并详细解释了Linux下进程的具体状态及其管理,此外,文章还讨论了进程的优先级、查看和修改进... 目录一、操作系统的进程状态1.1运行状态1.2阻塞状态1.3挂起二、linux下具体的状态三、进程的
阅读更多...
Python中的可视化设计与UI界面实现

Python中的可视化设计与UI界面实现

《Python中的可视化设计与UI界面实现》本文介绍了如何使用Python创建用户界面（UI）,包括使用Tkinter、PyQt、Kivy等库进行基本窗口、动态图表和动画效果的实现,通过示例代码,展示... 目录从像素到界面：python带你玩转UI设计示例：使用Tkinter创建一个简单的窗口绘图魔法：用
阅读更多...
python多进程实现数据共享的示例代码

python多进程实现数据共享的示例代码

《python多进程实现数据共享的示例代码》本文介绍了Python中多进程实现数据共享的方法,包括使用multiprocessing模块和manager模块这两种方法,具有一定的参考价值,感兴趣的可以... 目录背景进程、进程创建进程间通信 进程间共享数据共享list实践背景 安卓ui自动化框架，使用的是
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2