当前位置: 首页 > news >正文

进程间通讯-管道

介绍

管道(Pipe)是操作系统提供的一种进程间通信(IPC,Inter-Process Communication)机制,它允许一个进程的输出直接作为另一个进程的输入。管道主要分为以下两种类型:

  1. 无名管道(Unnamed Pipe)

    • 无名管道是半双工的,也就是说数据只能在一个方向上流动,要么从写入端流向读取端,要么反之。
    • 管道是存在于内存中的,由内核管理的一个缓冲区。
    • 管道的两端通过文件描述符(file descriptor)进行访问,通常是一个数组,如int fd[2],其中fd[0]用于读取,fd[1]用于写入。
    • 管道通常用于父子进程之间的通信,因为无名管道只能在具有亲缘关系的进程之间使用。
    • 当写入的数据超过管道的缓冲区容量时,写入操作会被阻塞,直到有进程从管道中读出数据。
  2. 命名管道(Named Pipe或FIFO,First-In-First-Out)

    • 命名管道是在文件系统中创建的一个特殊文件,因此它可以用于不相关的进程之间的通信。
    • 命名管道既可以用于半双工通信,也可以通过创建两个命名管道实现全双工通信。
    • 任何知道命名管道路径的进程都可以打开并使用它进行通信。
    • 命名管道的使用方式与普通文件类似,可以使用标准的文件I/O函数进行读写操作。

实现举例

#include <iostream>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>int main() {int pipefd[2];pid_t cpid;char buf;if (pipe(pipefd) == -1) {perror("pipe");exit(EXIT_FAILURE);}cpid = fork();if (cpid == -1) {perror("fork");exit(EXIT_FAILURE);}if (cpid == 0) {    // 子进程close(pipefd[1]);  // 关闭管道的写端while (read(pipefd[0], &buf, 1) > 0) {  // 从管道的读端读数据write(STDOUT_FILENO, &buf, 1);  // 将读到的数据输出到标准输出}write(STDOUT_FILENO, "\n", 1);close(pipefd[0]);  // 关闭管道的读端_exit(EXIT_SUCCESS);} else {            // 父进程close(pipefd[0]);  // 关闭管道的读端write(pipefd[1], "Hello, world!", 13);  // 向管道的写端写数据close(pipefd[1]);  // 关闭管道的写端wait(NULL);        // 等待子进程结束exit(EXIT_SUCCESS);}
}
示例说明

在上面的例子中,首先使用pipe()函数创建了一个管道,并获取了管道的两个文件描述符。然后,使用fork()函数创建了一个子进程。在子进程中,关闭了管道的写端,然后从管道的读端读取数据,并将读到的数据输出到标准输出。在父进程中,关闭了管道的读端,然后向管道的写端写入数据,并等待子进程结束。最后,在父进程中关闭了管道的写端,并结束了整个程序。

需要注意的是,管道是一种半双工的通信方式,数据只能单向流动。在上述例子中,创建了一个管道,并使用fork()函数创建了一个子进程。然后,在父进程中向管道的写端写入数据,在子进程中从管道的读端读取数据。由于管道是单向的,所以需要使用两个文件描述符来实现父子进程之间的双向通信。

总结

管道的主要特点和注意事项包括:

  • 管道中的数据是以字节流的形式传输的,不保留消息边界。
  • 管道的读写操作遵循先进先出(FIFO)的原则。
  • 管道的读端和写端都是独立的文件描述符,可以被不同的进程拥有。
  • 如果没有进程在读取管道中的数据,那么写入管道的操作可能会阻塞,直到有进程开始读取。
  • 当所有引用管道的进程都关闭了它们的文件描述符时,管道将被删除。
http://www.lryc.cn/news/262258.html

相关文章:

  • 项目总结-自主HTTP实现
  • Java语言+二维数组+非递归实现五子棋游戏
  • WordCloud—— 词云
  • linux网络----UDP编程
  • [AI工具推荐]AiRestful智能API代码生成
  • Elasticsearch 8.10.0同义词API用法详解,支持同义词热更新
  • 深度学习之模型权重
  • 纯前端使用XLSX导出excel表格
  • 将mjpg格式数转化成opencv Mat格式
  • 【golang/g3n】3D游戏引擎G3N的windows安装与测试
  • sap table 获取 valuation class MBEW 查表获取
  • 介绍一些操作系统—— Ubuntu 系统
  • React中props 和 state异同初探
  • spring-kakfa依赖管理之org/springframework/kafka/listener/CommonErrorHandler错误
  • 基于go语言开发的海量用户及时通讯系统
  • 19.Oracle 中count(1) 、count(*) 和count(列名) 函数的区别
  • C 库函数 - time()
  • 基于Python数据可视化的网易云音乐歌单分析系统
  • Jenkins----基于 CentOS 或 Docker 安装部署Jenkins并完成基础配置
  • flume系列之:监控flume agent channel的填充百分比
  • 信息安全和网络安全的区别
  • 【开源项目】WPF 扩展 -- 多画面视频渲染组件
  • risc-v system instruction
  • 08 v-text指令
  • vite基本知识
  • 考研真题c语言
  • neuq-acm预备队训练week 9 P8604 [蓝桥杯 2013 国 C] 危险系数
  • 【BIG_FG_CSDN】*VMware17pro*Linux*Redhit6网络管理(个人向——学习笔记)
  • Nginx location+Nginx rewrite(重写)(新版)
  • uniapp实现地图电子围栏功能