进程池设计

c++d281926eda>

代码目的头文件代码语言：c++复制

#include#include#include#include#include#include#include#include

对子进程操作建立子进程对象并把子进程对象放进数组里代码语言：c++复制

//创建子进程对象class  SubEp//endpoint---子进程对象{public:SubEp(pid_t subid,int writefd)//第一个参数是子进程的pid，第二个参数是该子进程读端对于父进程的写端fd:_subid(subid),_writefd(writefd){   char namebuffer[1024];   //第一个参数是表示第几号子进程，第二个参数是子进程的pid，第三个参数是该子进程读端对于的父进程的写端   snprintf(namebuffer,sizeof namebuffer,"process: %d [pid(%d) - fd(%d)]",num++,_subid,_writefd);   _name=namebuffer;}public:static int num;string _name;pid_t _subid;int _writefd;//该子进程与父进程匿名管道对于的父进程的写端fd};int SubEp::num=0;

子进程对象需要传递两个参数来初始化成员变量_subid和 _writefd。一是子进程的pid二是该子进程读端对应父进程写端的文件描述符fd成员变量num表示是第几个创建出来的子进程，第一个创建出来的子进程为0，使用后++后续子进程的num依次是1，2等等。因此num不能由于出了SubEp对象作用域后被销毁，所以定义为static，变量num生命周期取决于SubEp类的生命周期成员变量 _name用namebuffer初始化，用来标识该子进程的其他成员变量建立子进程需要执行的任务表代码语言：c++复制

//创建父进程给子进程派发的任务列表typedef void(*func_t)();//函数指针类型，函数返回值为voidvoid downloadTask()//模拟下载任务{    cout<*out){    assert(out);//vector创建成功    out->push_back(downloadTask);    out->push_back(fflushTask);    out->push_back(subscribeTask);}

子进程需要执行的任务都是函数对象，建立一个对象是函数指针的数组out，通过loadTaskFunc函数把任务函数尾插到数组out里，然后通过输出型参数返回。创建子进程和父进程通信的管道，并且让子进程阻塞读取代码语言：c++复制

void CreateSubProcesses( vector*subs,vector& funcMap){    vector deleteFd;//创建子进程并且创建好父进程与各个子进程通信的管道int fds[2];for(size_t i=0;i=0 && taskcodepush_back(sub);        deleteFd.push_back(fds[1]);//记录当前的写端供下个子进程用}

在函数CreateSubProcesses内，先建立父进程相连的匿名管道，然后创建子进程，子进程也拷贝了一份父进程的文件描述符表，能通过文件描述符连接到匿名管道，因此父子进程通信的管道建立完成。在父进程语句中，需要注意的是，通过传参数子进程的pid和此时子进程读端对于的父进程的写端fd给SubEP类构建子进程对象，并且将对象放进数组subs里。在子进程的语句中，通过receiveTask函数获取任务码代码语言：c++复制

int receiveTask(int readfd){    int retcode=0;//返回任务码    ssize_t s= read(readfd,&retcode,sizeof(retcode));//从读端读出来的任务码放到retcode里    cout<<"process has read the TaskCode: "<让子进程在receiveTask函数中阻塞读取管道里的数据。前提已知父进程往匿名管道写入整数数据，数据范围为0,任务个数-1即任务数组对应的下标范围，子进程把读取到的数据存到变量retcode里，然后判断retcode是否是整数数据大小，如果是就返回数据给上层CreateSubProcesses函数，如果不是就返回-1。当变量taskcode接收到receiveTask函数返回的任务码时，如果任务码符合范围0,任务个数-1即父子进程按照我们的意愿通信正常，然后子进程拿着任务码调用funcMap数组执行任务；但如果接收的返回值是-1，则是父子进程间通信不正常，直接退出判断语句。

这里提到的子进程操作主要是子进程阻塞读取父进程写入的数据，还有子进程拿到数据执行任务。
对父进程操作代码语言：c++复制
void loadBalanceContrl(const vector& subs,const vector &funcMap,int comcode){    int processnum=subs.size();//子进程的个数    int tasknum=funcMap.size();//任务的个数    bool numoftime=(comcode==0?true:false);//若命令码是0则一直运行，若命令码为正数x，则允许x次后退出    while(true)    {   //rand()为伪随机数   //1.找到哪一个子进程   int subIndex=rand()%processnum;    //2.找到哪一个执行哪一个任务   int taskIndex=rand()%tasknum;    //3.任务发送给选择的进程     sendTask(subs[subIndex],taskIndex);//第一个参数传第几个子进程，第二个参数传第几个任务     sleep(1);  if(!numoftime)  {    comcode--;    if(comcode==0)    break;  }    }    //走到这里则是父进程给子进程通信完了，需要逐个关闭子进程读端对于的写端--倒退关解决bug    for(size_t i=0;iloadBalanceContrl函数需要main函数传入子进程数组subs，任务数组funcMap和命令码comcode。comcode用来指定父进程发送多少次数据给子进程即子进程需要执行多少次任务numoftime用来鉴别父进程需要写入多少次数据，当comcode为0时则numoftime为真，则父进程死循环往匿名管道里写数据；若命令码为正数x为非0，则numoftime为假，则父进程往匿名管道里写x次数据。通过sendTask函数让父进程选择指定的子进程，写入指定的任务码到匿名管道中代码语言：c++复制
void sendTask(const SubEp& process, int tasknum){    cout<<"send Task num: "<父子间进程通信完之后，按照子进程创建时间从先往后依次关闭子进程读端对应的父进程的写端。回收子进程代码语言：c++复制
void waitProcess(const vector& processes){    for(size_t i=0;i按照子进程创建时间从先往后依次回收子进程。整体代码代码语言：c++复制
#include#include#include#include#include#include#include#includeusing namespace std;#define PROCESS_NUM 3#define MakeSeed() srand((unsigned long)time(nullptr)^getpid()^rand()%1234)//建立伪随机数种子//创建父进程给子进程派发的任务列表typedef void(*func_t)();//函数指针类型，函数返回值为voidvoid downloadTask()//模拟下载任务{    cout<*out){    assert(out);//vector创建成功    out->push_back(downloadTask);    out->push_back(fflushTask);    out->push_back(subscribeTask);}//创建子进程对象class  SubEp//endpoint---子进程对象{public:SubEp(pid_t subid,int writefd)//第一个参数是子进程的pid，第二个参数是该子进程读端对于父进程的写端fd:_subid(subid),_writefd(writefd){   char namebuffer[1024];   //第一个参数是表示第几号子进程，第二个参数是子进程的pid，第三个参数是该子进程读端对于的父进程的写端   snprintf(namebuffer,sizeof namebuffer,"process: %d [pid(%d) - fd(%d)]",num++,_subid,_writefd);   _name=namebuffer;}public:static int num;string _name;pid_t _subid;int _writefd;//该子进程与父进程匿名管道对于的父进程的写端fd};int SubEp::num=0;int receiveTask(int readfd){    int retcode=0;//返回任务码    ssize_t s= read(readfd,&retcode,sizeof(retcode));//从读端读出来的任务码放到retcode里    cout<<"process has read the TaskCode: "<*subs,vector& funcMap){    vector deleteFd;//创建子进程并且创建好父进程与各个子进程通信的管道int fds[2];for(size_t i=0;i=0 && taskcodepush_back(sub);       deleteFd.push_back(fds[1]);//记录当前的写端供下个子进程用}}void sendTask(const SubEp& process, int tasknum){    cout<<"send Task num: "<& subs,const vector &funcMap,int comcode){    int processnum=subs.size();//子进程的个数    int tasknum=funcMap.size();//任务的个数    bool numoftime=(comcode==0?true:false);//若命令码是0则一直运行，若命令码为正数x，则允许x次后退出    while(true)    {        //rand()为伪随机数   //1.找到哪一个子进程   int subIndex=rand()%processnum;    //2.找到哪一个执行哪一个任务   int taskIndex=rand()%tasknum;    //3.任务发送给选择的进程     sendTask(subs[subIndex],taskIndex);//第一个参数传第几个子进程，第二个参数传第几个任务     sleep(1);  if(!numoftime)  {    comcode--;    if(comcode==0)    break;  }    }    //走到这里则是父进程给子进程通信完了，需要逐个关闭子进程读端对于的父进程写端    for(size_t i=0;i& processes){    for(size_t i=0;i subs;//创建子进程对象并将子进程对象放进数组里vector funcMap;//建立一个任务表：父进程写入管道，子进程在管道读取，读取到的数据引导子进程去完成一些任务loadTaskFunc(&funcMap);//1.创建子进程并且创建好父进程与各个子进程通信的管道,并且让子进程阻塞等待父进程写入CreateSubProcesses(&subs,funcMap);//2.对父进程操作//父进程给子进程发送命令码，为0则一直运行，为正数x则运行x次后退出int Runcount=0;cout<<"请输入需要执行几次任务，输入0则为一直循环执行任务，请输入: ";cin>>Runcount;cout<子进程具有读端未关闭的bug
image-20250522164129612
image-20250522164147020
image-20250522164456853
通过上面的图例可以看到，2号子进程有一个写端与1号子进程的读端通信着。
得出结论：当父进程创建多个子进程，并且父进程作为写端而多个子进程作为读端从而进行进程间通信时，需要单独把子进程的所有写端都关闭。
这里提供两种方法关闭子进程的所有写端
方案一：在父进程创建子进程前构建一个vector对象，父进程创建子进程后，把父进程的写端放进vector里。等到父进程创建完下一个子进程时，vector里的写端即是当前子进程读端对应的上一个子进程的写端（有可能不只是一个写端），再把vector里的所有写端关闭即可。
image-20250522202611512
image-20250522203254968
这次实现就是用的这个方案，其实不用也可以，因为当父进程往匿名管道里写完数据时，先把父进程对应各个子进程的写端全部关闭，然后再将全部子进程进行回收，这种顺序不会出现bug；但如果是按照创建子进程时间从旧往新关掉一个父进程的写端，然后立刻等待回收一个相应的子进程的话，会导致出现该子进程读端还有其他子进程的写端通信着，该子进程读端没有读到0导致子进程没有正常退出，那么父进程也就回收不到子进程。方案二：在父进程关闭写端，需要所有子进程关闭读端时，依次按照创建的时间从新往旧（从后往前）关闭父进程的写端。由于最后创建的子进程的读端只对应父进程的写端，那么父进程关闭写端时，最后一个子进程的读端读到0正常关闭读端，那么该子进程的文件描述符表也会被关闭，进而该子进程正常退出，从而该子进程连接着前一个子进程的写端也会被关闭；那么轮到下一个子进程时，该子进程的读端也只会对应父进程的写端，父进程关闭写端，子进程读端读到0正常关闭读端，子进程正常退出。          


# linux 
# c++ 
# 作用域 
# typedef 
# Static 
# 成员变量 
# 循环 
# 指针 
# 对象 
# bug 
# 上一 
# 第一个 
# 第二个 
# 的是 
# 随机数 
# 也会 
# 读到 
# 几个 
# 完成任务 
# 则是 
 




相关栏目：
    【
        网站优化151355    】
    【
        网络推广146373    】
    【
        网络技术251813    】
    【
        AI营销90571    】




相关推荐：
Laravel如何生成URL和重定向？（路由助手函数） 
HTML透明颜色代码在Angular里怎么设置_Angular透明颜色使用指南【详解】 
JavaScript如何实现路由_前端路由原理是什么 
如何快速查询网址的建站时间与历史轨迹？ 
bootstrap日历插件datetimepicker使用方法 
企业网站制作这些问题要关注 
laravel怎么配置和使用PHP-FPM来优化性能_laravel PHP-FPM配置与性能优化方法 
如何快速搭建虚拟主机网站？新手必看指南 
百度输入法全感官ai怎么关 百度输入法全感官皮肤关闭 
HTML5空格在Angular项目里怎么处理_Angular中空格的渲染问题【详解】 
google浏览器怎么清理缓存_谷歌浏览器清除缓存加速详细步骤 
Laravel如何生成API文档？（Swagger/OpenAPI教程） 
微信小程序 canvas开发实例及注意事项 
Laravel如何集成第三方登录_Laravel Socialite实现微信QQ微博登录 
 网站制作价目表怎么做,珍爱网婚介费用多少？ 
PHP 500报错的快速解决方法 
如何在服务器上配置二级域名建站？ 
利用python获取某年中每个月的第一天和最后一天 
 免费网站制作appp,免费制作app哪个平台好？ 
Linux系统命令中screen命令详解 
Laravel模型关联查询教程_Laravel Eloquent一对多关联写法 
EditPlus 正则表达式 实战(3) 
 创业网站制作流程,创业网站可靠吗？ 
HTML5打空格有哪些误区_新手常犯的空格使用错误【技巧】 
如何在IIS中配置站点IP、端口及主机头？ 
Edge浏览器提示“由你的组织管理”怎么解决_去除浏览器托管提示【修复】 
js实现点击每个li节点，都弹出其文本值及修改 
千问怎样用提示词获取健康建议_千问健康类提示词注意事项【指南】 
 油猴 教程,油猴搜脚本为什么会网页无法显示？ 
Python并发异常传播_错误处理解析【教程】 
详解免费开源的.NET多类型文件解压缩组件SharpZipLib（.NET组件介绍之七） 
HTML5段落标签p和br怎么选_文本排版常用标签对比【解答】 
如何用JavaScript实现文本编辑器_光标和选区怎么处理 
如何在香港服务器上快速搭建免备案网站？ 
谷歌浏览器如何更改浏览器主题 Google Chrome主题设置教程 
 太平洋网站制作公司,网络用语太平洋是什么意思？ 
nodejs redis 发布订阅机制封装实现方法及实例代码 
 购物网站制作费用多少,开办网上购物网站，需要办理哪些手续？ 
JavaScript中如何操作剪贴板_ClipboardAPI怎么用 
Android GridView 滑动条设置一直显示状态(推荐) 
Laravel Blade组件怎么用_Laravel可复用视图组件的创建与使用 
Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件 
高端网站建设与定制开发一站式解决方案  中企动力 
UC浏览器如何设置启动页 UC浏览器启动页设置方法 
网站建设保证美观性，需要考虑的几点问题！ 
Laravel如何使用Eloquent进行子查询 
 南京网站制作费用,南京远驱官方网站？ 
Swift中循环语句中的转移语句 break 和 continue 
标题：Vue + Vuex + JWT 身份认证的正确实践与常见误区解析 
Laravel软删除怎么实现_Laravel Eloquent SoftDeletes功能使用教程