【Linux】匿名管道与命名管道,进程池的简易实现

news2024/11/16 8:42:40

文章目录

  • 前言
  • 一、匿名管道
    • 1.管道原理
    • 2.管道的四种情况
    • 3.管道的特点
  • 二、命名管道
    • 1. 特点
    • 2.创建命名管道
      • 1.在命令行上
      • 2.在程序中
    • 3.一个程序执行打开管道并不会真正打卡
  • 三、进程池简易实现
    • 1.makefile
    • 2.Task.hpp
    • 3.ProcessPool.cpp


前言

一、匿名管道

#include <unistd.h>
功能:创建一无名管道
原型
int pipe(int fd[2]);
参数:
fd:文件描述符数组,其中fd[0]表示读端, fd[1]表示写端
返回值:成功返回0,失败返回错误代码

1.管道原理

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

本质是先让不同的进程看到同一份资源,也就是两个进程都能对管道文件的缓冲区进行操作

这里我们pipe的时候,会使用两个文件描述符,这两个文件描述里面存的file结构体是同一个,也就是管道文件的file结构体,file结构体中存储有inode以及系统缓冲区,此时fork一个子进程,子进程有着和父进程一样的结构,
这里有一个非常重要的点虽然子进程有着自己的进程地址空间,也有着自己存储file结构体的指针数组,但是其数组里面的内容是和父进程一样的,也就是子进程里面pipe对应的文件描述符位置指向的file结构体(管道文件)是同一个,至此我们父子进程就看到了同一个资源,可以利用这个资源进行通信

两个不同的进程打开同一份文件的时候,在内核中,操作系统只会打开一个
在这里插入图片描述

2.管道的四种情况

1.读写端正常,管道如果为空,读端就要阻塞
读写端正常,管道如果被写满,写端就要阻塞
2.读端正常读,写端关闭,读端就会读到0,表明读到了管道文件的结尾,不会被阻塞,如果我们打印读端读到的内容,显示器会一直显示0
3.写端正常写入,读端关闭,操作系统会杀掉此时正在写入的进程(通过信号来杀掉)
4.因为操作系统不会做低效,浪费的事情,我读端都不读了,你写入再多数据到一个管道里面有什么用,因为管道不占用磁盘内存,所以程序结束后,就没有管道的存在了。

当要写入的数据量不大于PIPE_BUF时,linux将保证写入的原子性。
当要写入的数据量大于PIPE_BUF时,linux将不再保证写入的原子性。

3.管道的特点

1.只能用于具有共同祖先的进程(具有亲缘关系的进程)之间进行通信;通常,一个管道由一个进程创建,然后该进程调用fork,此后父、子进程之间就可应用该管道。
2.管道提供流式服务
3.一般而言,进程退出,管道释放,所以管道的生命周期随进程
4.一般而言,内核会对管道操作进行同步与互斥
5.管道是半双工的,数据只能向一个方向流动;需要双方通信时,需要建立起两个管道

二、命名管道

1. 特点

1.管道应用的一个限制就是只能在具有共同祖先(具有亲缘关系)的进程间通信。
2.如果我们想在不相关的进程之间交换数据,可以使用FIFO文件来做这项工作,它经常被称为命名管道
3.命名管道是一种特殊类型的文件

2.创建命名管道

1.在命令行上

 mkfifo  +文件名

2.在程序中

int mkfifo(const char *filename,mode_t mode);

int main(int argc, char *argv[])
{
 mkfifo("p2", 0644);
 return 0;
}

3.一个程序执行打开管道并不会真正打卡

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

我们执行这个程序发现并没有打印那句话,说明管道文件并没有真正打开,只有当我们执行另一个我们要通信的文件的时候,管道才会真正打开
在这里插入图片描述

三、进程池简易实现

1.makefile

ProcessPool:ProcessPool.cpp
	g++ -o $@ $^ -std=c++11  -g

.PHONY:clean
clean:
	rm -rf ProcessPool

2.Task.hpp

 #pragma once
#include<functional>
 #include<vector>
 #include<iostream>
 using namespace std;
 

void task1()
{
    std::cout << "lol 刷新日志" << std::endl;
}
void task2()
{
    std::cout << "lol 更新野区,刷新出来野怪" << std::endl;
}
void task3()
{
    std::cout << "lol 检测软件是否更新,如果需要,就提示用户" << std::endl;
}
void task4()
{
    std::cout << "lol 用户释放技能,更新用的血量和蓝量" << std::endl;
}


void LoadTask(vector<function<void()>>*tasks){
tasks->push_back(task1);
tasks->push_back(task2);
tasks->push_back(task3);
tasks->push_back(task4);
return ;
}

3.ProcessPool.cpp

在这里插入图片描述

我们创建processnum个子进程,让父进程来写,子进程来读,子进程读到任务号后进行对应的处理。

#include <iostream>
#include "Task.hpp"
#include <assert.h>
#include <vector>
#include <string>
#include <unistd.h>
#include <sys/wait.h>
#include <sys/types.h>

using namespace std;
vector<function<void()>> tasks;
const int processnum = 10;//创建的子进程数
class channel
{
public:
    channel(  string processname,  pid_t slaverid,int cmdcode)
        : _processname(processname), _cmdfd(cmdcode), _slaverid(slaverid)
    {
    }

public:
    string _processname;//执行任务的进程名

    pid_t _slaverid;//执行任务的进程pid

    int _cmdfd;//朝几号管道去操作
};

void Menu()
{
    std::cout << "################################################" << std::endl;
    std::cout << "# 1. 刷新日志             2. 刷新出来野怪        #" << std::endl;
    std::cout << "# 3. 检测软件是否更新      4. 更新用的血量和蓝量  #" << std::endl;
    std::cout << "#                         0. 退出               #" << std::endl;
    std::cout << "#################################################" << std::endl;
}

void slaver()
{
    int cmdcode;
    while (true)
    {
        int n = read(0, &cmdcode, sizeof(int));//读取任务码
        if (n == sizeof(int))
        {
            cout << "slaver say get a command " << getpid() << " cmdcode:  " << cmdcode << endl;
            if (cmdcode >= 0 && cmdcode < tasks.size())
                tasks[cmdcode]();//执行任务
        }
        else if (n == 0)//为0,说明读到文件末尾,之间break
            break;
    }
}
void InitProcessPool(vector<channel> *channels)
{
    for (int i = 0; i < processnum; i++)
    {
        int pipefd[2] = {0};
        int n = pipe(pipefd);
        //使用两个文件描述符指向同一个管道文件
        assert(!n);
        pid_t id = fork();

        if (id == 0)//子进程
        {
            close(pipefd[1]);//关闭写文件
            dup2(pipefd[0], 0);//将读文件重定向到标准输入的位置
            close(pipefd[0]);//关闭当前读文件,因为我们后续用标准输入的下标就行了
            slaver();//子进程读取任务码
            exit(0);
        }
        string name = "processname " + to_string(i);//子进程名字
        channels->push_back(channel(name, id, pipefd[1]));//子进程pid,这个子进程
        //与父进程之间的管道文件描述符下标记录下来

        // father
        close(pipefd[0]);//关闭读文件
    }
}

void ctrlProcess(vector<channel> &channels)
{
    int which = 0;
//我们循环调用各个子进程,which为子进程的下标
    while (true)
    {
         Menu();
        int select = 0;
        cin >> select;
        
        cout << "Please Enter@ ";
        if (select <= 0 || select >= 5)
            break;
        int cmdcode = select - 1;

        cout << "father say task have sent to " << channels[which]._processname << "  cmdcode : " << cmdcode << endl;
        write(channels[which]._cmdfd, &cmdcode, sizeof(int));//写入指令
        which++;
        which %= channels.size();
    }
}

void QuitProcess(const vector<channel> channels)
{
    //方法一:
    for (const auto &c : channels)
        close(c._cmdfd);

    for (const auto &c : channels)
        waitpid(c._slaverid, nullptr, 0);

    //方法二:
    //for(int i=channels.size()-1;i>=0;i--){
      //  close(channels[i]._cmdfd);
        //waitpid(channels[i]._slaverid,nullptr,0);//阻塞等待
    //}
}

int main()
{

    vector<channel> channels;//管理管道的数组
    LoadTask(&tasks);//加载任务
    InitProcessPool(&channels);//初始化进程池
    ctrlProcess(channels);//输入任务命令
    QuitProcess(channels);//中止进程
    return 0;
}

如果等待和close在一个循环中会发生阻塞,因为我一号管道虽然父进程那里写关闭了,但依旧有子进程2,3指向这个管道为写

在这里插入图片描述

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

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

相关文章

死磕Nacos系列:Nacos在我的SpringCloud项目中做了什么?

Nacos服务注册 我们一个SpringCloud项目中集成了Nacos&#xff0c;当项目启动成功后&#xff0c;就可以在Nacos管理界面上看到我们项目的注册信息&#xff0c;还可以看到项目的健康状态等等信息&#xff1a; 那Nacos是什么时候进行了哪些操作的呢&#xff1f;今天我们来一探究…

数据挖掘 K近邻

什么时候用K近邻&#xff1f; 交叉验证的时候。最常见的交叉验证方法是K折交叉验证&#xff0c;其中数据集被均匀分成K个子集&#xff0c;称为折&#xff0c;然后执行K次训练和测试&#xff0c;每次选择不同的折作为测试集&#xff0c;其余的作为训练集。最后&#xff0c;将K次…

qt5.15.2及6.0以上版本安装

文章目录 下载在线安装器安装打开软件 下载在线安装器 因为从qt5.15开始不支持离线下载安装了&#xff0c;只能通过在线安装的方式进行安装。 下载在线安装下载器&#xff1a; 这个在线安装下载器网上也都是可以找到。 这里是其放到网盘上的下载地址&#xff1a; 链接&#x…

DBT踩坑第二弹

总结下dbt-spark踩到的坑&#xff0c;连接方式采用的是thrift连接 Kerberos认证。考虑到开源组件Kyuubi也是基于Hiveserver2&#xff0c;使用的thrift协议&#xff0c;所以采用Kyuubi执行SparkSQL。 官方文档给出的Thrift方式连接示例真的是简单&#xff0c;但是真是用起来真是…

01_MySQL介绍及安装

#任务背景 一、真实案例 某公司现在有几套不同版本的MySQL数据库&#xff0c;现在大部分的生产和测试环境都已经切换到5.7版本&#xff0c;由于历史原因&#xff0c;有一套测试环境版本为MySQL-5.5。现为了将测试环境版本统一&#xff0c;需要将原来测试环境数据库MySQL-5.5版…

Linux:创建进程 -- fork,到底是什么?

相信大家在初学进程时&#xff0c;对fork函数创建进程一定会有很多的困惑&#xff0c;比如&#xff1a; 1.fork做了什么事情?? 2.为什么fork函数会有两个返回值?3.为什么fork的两个返回值&#xff0c;会给父进程谅回子进程pid&#xff0c;给子进程返回0?4.fork之后:父子进…

哨兵1号回波数据(L0级)包格式解析与成像参数提取

坑爹的格式,具体有多坑往下看就知道了。matlab代码在文末。 先上首字母缩写: 再来回波数据包的格式图 1. 数据包格式 众所周知,解包的第一步是找帧头和帧长,找到第4~5字节,帧长码为“0x3761”,转十进制为14777,然而实际第一帧整帧的长度是14184。。。你要是加6我还能…

机器学习与因果推断的高级实践 | 数学建模

文章目录 因果推断因果推断的前世今生&#xff08;1&#xff09;潜在结果框架&#xff08;Potential Outcome Framework&#xff09;&#xff08;2&#xff09;结构因果模型&#xff08;Structual Causal Model&#xff0c;SCM&#xff09; 身处人工智能爆发式增长时代的机器学…

LeetCode OJ循环队列(C语言)

1.题目的初步分析 我们分析上述题目的时候会发现题目非常的长&#xff0c;不好整理思路&#xff0c;我这里可以大致的将本题的几个核心点说出来&#xff1a; 1.队列的思路 循环队列说来说去不还是队列嘛&#xff0c;那么队列的基本操作增删查改、以及队列的基本结构肯定都是不能…

京东家用电器商品电子说明书在哪里能找到怎么查看产品电子说明书?草柴返利APP如何查询领取京东优惠券拿京东购物返利?

京东商品电子说明书是一种便捷、高效的说明工具&#xff0c;为消费者了解和使用商品提供了重要帮助。京东商品电子说明书是一种以电子文档、图文、视频的形式提供的商品使用说明书。它通常由商家上传至京东平台&#xff0c;以供消费者在购买商品后下载查看。与传统的纸质说明书…

计算机编程零基础编程学什么语言,中文编程工具构件简介软件下载

计算机编程零基础编程学什么语言&#xff0c;中文编程工具构件简介软件下载 给大家分享一款中文编程工具&#xff0c;零基础轻松学编程&#xff0c;不需英语基础&#xff0c;编程工具可下载。 这款工具不但可以连接部分硬件&#xff0c;而且可以开发大型的软件&#xff0c;象如…

Leetcode—94.二叉树的中序遍历【简单】

2023每日刷题&#xff08;四十&#xff09; Leetcode—94.二叉树的中序遍历 C语言实现代码 /*** Definition for a binary tree node.* struct TreeNode {* int val;* struct TreeNode *left;* struct TreeNode *right;* };*/ /*** Note: The returned array mus…

Java实现—数据结构 1.初识集合框架

一、什么是集合框架 Java集合框架&#xff0c;又被称为容器&#xff0c;是定义在java.util包下的一组接口interfaces和其实现类classes 其主要表现为将多个元素element置于一个单元中&#xff0c; 集合框架是由若干个类组成的&#xff0c;每个类的背后就是一种数据结构&…

2023.11.25更新关于mac开发APP(flutter)的笔记与整理(实机开发一)

我自己写的笔记很杂&#xff0c;下面的笔记是我在chatgpt4的帮助下完成的&#xff0c;希望可以帮到正在踩坑mac开发APP&#xff08;flutter&#xff09;的小伙伴 目标&#xff1a;通过MAC电脑使用flutter框架开发一款适用于苹果手机的一个APP应用 本博客的阅读顺序是&#xf…

2022年06月 Scratch(三级)真题解析#中国电子学会#全国青少年软件编程等级考试

Scratch等级考试(1~4级)全部真题・点这里 一、单选题(共25题,每题2分,共50分) 第1题 点击绿旗,舞台上的角色会说出? A:2022年5月1日 B:1日5月2022年 C:2022年05月01日 D:05月01日2022年 答案:C 输出为:2022年05月01日。 第2题 观察规律,请问橙色方块应填…

小程序项目:node+vue基于微信小程序的校园盲盒小程序的设计与实现

项目介绍 随着信息技术和网络技术的飞速发展&#xff0c;人类已进入全新信息化时代&#xff0c;传统管理技术已无法高效&#xff0c;便捷地管理信息。为了迎合时代需求&#xff0c;优化管理效率&#xff0c;各种各样的管理系统应运而生&#xff0c;各行各业相继进入信息管理时…

frp V0.52.3 搭建

下载 https://github.com/fatedier/frp/releases/ 此版本暂时没有windows的&#xff0c;想在windows使用请下载v0.52.2 简易搭建 frps.toml的配置文件&#xff0c;以下12000、8500需要在云服务器中的防火墙中开放tcp # bindPort为frps和frpc通信的端口&#xff0c;需要在防…

QT已有项目导入工程时注意事项

文章目录 从qt其他版本上开发的工程导入另一qt版本时 从qt其他版本上开发的工程导入另一qt版本时 这里以之前在qt5.12.2上开发的项目为例&#xff0c;现在到在qt6.5.3上运行。 不能直接导入IDE上&#xff0c;否则会报各种莫名奇妙的错误。 首先要把扩展名位.pro.user文件 删掉…

电子学会C/C++编程等级考试2021年03月(二级)真题解析

C/C++等级考试(1~8级)全部真题・点这里 第1题:石头剪刀布 石头剪刀布是常见的猜拳游戏。石头胜剪刀,剪刀胜布,布胜石头。如果两个人出拳一样,则不分胜负。 一天,小A和小B正好在玩石头剪刀布。已知他们的出拳都是有周期性规律的,比如:“石头-布-石头-剪刀-石头-布-石头…

[JVM] 京东一面~说一下Java 类加载过程

系统加载 Class 类型的文件主要三步&#xff1a;加载->连接->初始化。连接过程又可分为三步&#xff1a;验证->准备->解析。 通过全限定名来加载生成 class 对象到内存中&#xff0c;然后进行验证这个 class 文件&#xff0c;包括文件格式校验、元数据验证&#xf…