因为我们让父进程发送五条信息，子进程收到五条信息后也就推出了！此时就完成了我们通过管道进行进程间通信了！！

对父进程代码稍作修改

在父进程中我们每次写入后都sleep(1);然后子进程读入的时候也是休眠1秒后在读取，所以我们可以发现:1.当父进程没有写入数据的时候，子进程会在等！所以，父进程写入之后，子进程才能read(会返回)到数据，子进程打印读取数据要以父进程的节奏为主！

所以父进程和子进程在读写的时候，是有一定顺序的！！

但是我们以前父子进程各自printf(向显示器写入)的时候，打印出来的语句是没有顺序的！(缺乏访问控制！)

所以我们可以得出结论：管道内部没有数据，reader就必须阻塞等待(read)。管道内部，如果数据被写满，writer就不必须阻塞等待(write);

阻塞等待的本质就是将当前进程的task_struct放入等待队列中！（R->S/D/T）

所以，pipe内部自带访问控制机制！！

父进程指派给子进程任务

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include using namespace std;typedef void (*functor)();vector functors; //方法集合// for debug
unordered_map info;void f1()
{cout << "这是一个处理日志的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}
void f2()
{cout << "这是一个备份数据的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}
void f3()
{cout << "这是一个处理网络链接的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}void loadFunctor()
{info.insert({functors.size(), "这是一个处理日志的任务"});functors.push_back(f1);info.insert({functors.size(), "这是一个备份数据的任务"});functors.push_back(f2);info.insert({functors.size(), "这是一个处理网络链接的任务"});functors.push_back(f3);
}
int main()
{// 0.加载任务列表loadFunctor();// 1.创建管道int pipefd[2] = {0};if (pipe(pipefd) != 0){cerr << "pipe error" << endl;return 1;}// 2.创建子进程pid_t id = fork();if (id < 0){cerr << "fork error" << endl;return 2;}else if (id == 0){//子进程进行读操作---read// 3.关闭不需要的文件fdclose(pipefd[1]);// 4.业务处理while (true){uint32_t opeartorType = 0;//如果有数据，就读取，如果没有数据，就阻塞等待，等待任务的到来ssize_t s = read(pipefd[0], &opeartorType, sizeof(uint32_t));if (s == 0){cout << "我要退出啦，我是子进程，父进程都退出了！" << endl;break;}assert(s == sizeof(uint32_t));// assert断言,是变异有效的debug模式// release模式下，断言也就没有了//一旦断言没有了，s变量就只是被定义，没有被使用。release摸下中，可能会warning(void)s;if (opeartorType < functors.size()){functors[opeartorType]();}else{cerr << "bug opeartorType" << endl;}}close(pipefd[0]);exit(0);}else{srand((long long)time(nullptr));//父进程进行写操作----write// 3.关闭不需要的文件fdclose(pipefd[0]);// 4.指派任务uint32_t num = functors.size();int cnt = 0;while (cnt < 10){// 5.形成任务码int commandCode = rand() % num;std::cout << "父进程指派任务完成，任务是: " << info[commandCode] << "任务的编号是: " << cnt << std::endl;// 向指定的进程下达执行任务的操作write(pipefd[1], &commandCode, sizeof(uint32_t));sleep(1);cnt++;}close(pipefd[1]);pid_t ret = waitpid(id, nullptr, 0);if (ret){cout << "wait success" << endl;}}
}

父进程通过给子进程发送不同的信号，让子进程完成不同的任务！！！

接下来如果通过父进程控制一批子进程呢？？

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include using namespace std;typedef void (*functor)();
vector functors; //方法集合// for debug
unordered_map info;void f1()
{cout << "这是一个处理日志的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}
void f2()
{cout << "这是一个备份数据的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}
void f3()
{cout << "这是一个处理网络链接的任务，执行的进程 ID [" << getpid()<< "],执行的时间是[" << time(nullptr) << "]\n\n" << endl;
}void loadFunctor()
{info.insert({functors.size(), "这是一个处理日志的任务"});functors.push_back(f1);info.insert({functors.size(), "这是一个备份数据的任务"});functors.push_back(f2);info.insert({functors.size(), "这是一个处理网络链接的任务"});functors.push_back(f3);
}// int32_t:进程pid,int32_t:该进程对应的写端fd
typedef std::pair elem;
int processNum = 5;void work(int blockFd)
{cout<<"进程 ["<   //a.阻塞等待   b.获取任务信息uint32_t operatorCode=0;ssize_t s=read(blockFd,&operatorCode,sizeof(uint32_t));if(s==0)break;assert(s==sizeof(uint32_t));(void)s;//c.处理任务if(operatorCodefunctors[operatorCode]();}}cout<<"进程 ["<& assignMap)
{srand((long long)time(nullptr));while(true){sleep(1);//选择一个进程,选择进程是随机的，没有压着一个进程一直给任务//较为均匀的将任务给所有子进程 ---负载均衡uint32_t pick=rand()%assignMap.size();//选择一个任务uint32_t task=rand()%functors.size();//把任务给一个指定的进程write(assignMap[pick].second,&task,sizeof(uint32_t));//打印对应的提示信息cout<<"父进程指派任务->"<loadFunctor();vector assignMap;//创建processNum个子进程for (int i = 0; i < processNum; i++){//定义保存管道的fd的对象int pipefd[2] = {0};//创建管道pipe(pipefd);//创建子进程pid_t id = fork();if (id == 0){//子进程读取，rclose(pipefd[1]);//子进程执行work(pipefd[0]);close(pipefd[0]);exit(0);}//父进程做的事情close(pipefd[0]);elem e(id,pipefd[1]);assignMap.push_back(e);}cout<<"create all process success!"<if(waitpid(assignMap[i].first,nullptr,0)>0){cout<<"wait for:pid=["<

#pragma once
#include
#include
#include
#include
#include
#include
#include
#include
#include#define IPC_PATH "./.fifo"

//写入
#include"comm.h"
using namespace std;
#define NUM 1024
int main()
{int pipeFd=open(IPC_PATH,O_WRONLY);if(pipeFd<0){cerr<<"open: "<printf("请输入你的消息# ");fflush(stdout);memset(line,0,sizeof(line));if(fgets(line,sizeof(line),stdin)!=nullptr){line[strlen(line)-1]='\0';write(pipeFd,line,strlen(line));}else{break;}}close(pipeFd);cout<<"客户端退出啦!"<

//读取
#include"comm.h"
using namespace std;
#define NUM 1024int main()
{extern int error;if(mkfifo(IPC_PATH,0666)!=0){cerr<<"mkfifo error"<cerr<<"open error"<ssize_t s=read(pipeFd,buffer,sizeof(buffer)-1);if(s>0){buffer[s]='\0';cout<<"客户端->服务器# "<cout<<"客户端退出啦，我也退出吧！"<//do nothingcout<<"read "<