亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 學院 > 開發設計 > 正文

多線程編程-通過fork方式創建任務進程

2019-11-06 06:05:38
字體:
來源:轉載
供稿:網友

背景

在多進程中需要創建一個任務進程進行待處理任務的分發工作。也就是說,需要在主進程中detach剝離出一個進程,且該子進程獨立于主進程,進行獨立的任務發送。如果是單純在主進程中fork一個子進程的話,如果進行了wait等待操作,那么該任務進程就失去了獨立性,無法實現邊取任務邊分發任務。而如果是不進行wait等待操作的話,那么子進程可能也會執行后續創建多個處理任務的進程,使得出現的并行進程數量為預期的double。當然這也是可以通過在并發多進程wait之前對任務分配進程進行wait操作來達到預期要求。本文采取兩種方式來實現任務分配進程和任務處理進程的共存。

方案1:

雙fork方式,以孫進程作為detach主進程的任務分配進程,由于該進程是游離于主進程的,所以其回收是通過系統實現的。

代碼

void childPRocnew_hash_test(){ struct msgstrunew_hash_align msgs; int msgid,ret_value; char str[512]; /* First, we set up the message queue. */ // msgid = msgget((key_t)MSGKEY, 0666 | ipC_CREAT);//該鍵值則唯一對應一個消息隊列 while(1) { msgid = msgget(MSGKEY,IPC_EXCL );/*檢查消息隊列是否存在 */ if(msgid < 0){ printf("msq not existed! errno=%d [%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } /*接收消息隊列*/ ret_value = msgrcv(msgid,&msgs,sizeof(struct msgstrunew_hash_align),0,0); std::cout<<"get task pid="<<getpid()<<","<<msgs.msgtext<<std::endl; usleep(100); if(ret_value == -1) { fprintf(stderr, "msgrcv failed with error: %d/n", errno);//消息隊列中的信息被取完?? exit(EXIT_FAILURE);//消息隊列為空的時候,就跳出。也可以設計成,消息隊列為空時,不跳出,而是等待。 } else { std::string hashline = msgs.msgtext;//接收到的是一行的信息,需要將該行的數據進行切分 // std::cout<<hashline.c_str()<<std::endl;// if (hashline.size()<10) { printf("datasize=%d,data=%s/n",hashline.size(),hashline.c_str()); exit(EXIT_SUCCESS);//換成break的效果呢???是不一樣的啊 } } //因為在send的時候,只send了一個end,當該標志信息被讀取之后,其他的進程自然是讀取不到信息的, } return;}void SendHashLine(){ struct msgstrunew_hash_align msgs; int msg_type; char str[80]; int ret_value; int msqid; msqid=msgget(MSGKEY,IPC_EXCL ); /*檢查消息隊列是否存在*/ if(msqid < 0){ msqid = msgget(MSGKEY,IPC_CREAT|0666);/*創建消息隊列*/ if(msqid <0){ printf("failed to create msq | errno=%d [%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } } ifstream m_InStream("hash_list.txt"); string oneline; int running=1; int linenun=0; while (running) { if(!getline(m_InStream, oneline,'/n')) { running = 0; for(int i = 0; i<ChildNum;++i) { msgs.msgtype = linenun; snprintf(msgs.msgtext,sizeof(msgs.msgtext),"%s","nil");//strncpy(response.m_ClientIp, request.m_ClientIp, sizeof(response.m_ClientIp));//記錄客戶端的ip,昵稱服務需要 // msgs.msgtext = "nil"; // strcpy(msgs.msgtext, str); /* 發送消息隊列 */ std::cout<<"task deliver pid="<<getpid()<<","<<msgs.msgtext<<std::endl; ret_value = msgsnd(msqid,&msgs,sizeof(struct msgstrunew_hash_align),0);//消息隊列標識符,準備發現信息的指針,信息的長度,控制標志位 if ( ret_value < 0 ) { printf("msgsnd() write msg failed,errno=%d[%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } } break; } linenun++; strncpy(str,oneline.c_str(),80); msgs.msgtype = linenun; // msgs.msgtext = str; strncpy(msgs.msgtext,str,sizeof(msgs.msgtext)); // strcpy(msgs.msgtext, str); /* 發送消息隊列 */ std::cout<<"task deliver pid="<<getpid()<<","<<msgs.msgtext<<std::endl; int test_len = sizeof(struct msgstrunew_hash_align); ret_value = msgsnd(msqid,&msgs,sizeof(struct msgstrunew_hash_align),0);//消息隊列標識符,準備發現信息的指針,信息的長度,控制標志位 // sleep(1); if ( ret_value < 0 ) { printf("msgsnd() write msg failed,errno=%d[%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } }}void MultiOldAligndata_test(){ //先用一個進程進行任務的創建,即用一個進程做消息隊列的創建 pid_t fpid; //fpid表示fork函數返回的值 int count=0; fpid=fork(); if (fpid < 0) printf("error in fork!"); else if (fpid == 0) { printf("i am the child process, my process id is %d/n",getpid()); printf("子進程/n"); count++; pid_t fpid_2; fpid_2 = fork(); if(fpid_2 <0) { printf("error in fork_second!/n"); } else if(fpid_2 == 0) { //該孫進程處理自己想要做的事情,即做任務的分配 SendHashLine();// } exit(EXIT_SUCCESS); } else { printf("i am the parent process, my process id is %d/n",getpid()); count++; } int status_1 =0; int mpid_1 =0; mpid_1 = wait(&status_1); //基于消息隊列的多進程版本----------begin---------------------------- time_t start,stop; start = time(NULL); int data_processed; string some_data; int i,cpid; // /* create 5 child process */ for (i=0;i<ChildNum;i++){ cpid = fork(); if (cpid < 0) printf("fork failed/n"); else if (cpid ==0) /*child process*/ { childprocnew_hash_test(); } } int status =0; int mpid =0; for(int i=0;i<ChildNum;i++) { mpid = wait(&status); printf("pid[%d] is exit with status[%d]/n",mpid,status); } stop = time(NULL); std::cout<<"cost:"<<double(stop-start)<<std::endl; //基于消息隊列的多進程版本----------end----------------------------

如果采用主進程直接fork一個子進程作為任務分配進程的話,該任務分配子進程也會執行后期的任務處理進程的多進程創建,使得并行的進程數是預期的double。 且由于主進程的等待操作并沒有考慮到這多出來的一倍進程,導致這部分進程沒有退出,僵死狀態。同時,任務分配進程也沒有退出。所以此時通過ps命令查看,發現進程數為7(=5并行進程+2(任務分配進程和主進程)) 并行執行過程輸出界面信息: 這里寫圖片描述 ps查看進程情況: 可以查看對應的進程號是與上面多出來的一倍進程相對應的。 這里寫圖片描述

方案2:

通過主進程fork一個子進程作為任務分配進程。主進程創建多個并發的任務處理進程。且在主進程wait各個任務處理進程之前進行一次任務進程的wait操作,使得任務進程得以回收,再進程并發進程的wait操作。

代碼:

//exit with statusvoid childprocnew_hash_test(){ struct msgstrunew_hash_align msgs; int msgid,ret_value; char str[512]; /* First, we set up the message queue. */ // msgid = msgget((key_t)MSGKEY, 0666 | IPC_CREAT);//該鍵值則唯一對應一個消息隊列 while(1) { msgid = msgget(MSGKEY,IPC_EXCL );/*檢查消息隊列是否存在 */ if(msgid < 0){ printf("msq not existed! errno=%d [%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } /*接收消息隊列*/ ret_value = msgrcv(msgid,&msgs,sizeof(struct msgstrunew_hash_align),0,0); std::cout<<"get task pid="<<getpid()<<","<<msgs.msgtext<<std::endl; usleep(100); if(ret_value == -1) { fprintf(stderr, "msgrcv failed with error: %d/n", errno);//消息隊列中的信息被取完?? exit(EXIT_FAILURE);//消息隊列為空的時候,就跳出。也可以設計成,消息隊列為空時,不跳出,而是等待。 } else { std::string hashline = msgs.msgtext;//接收到的是一行的信息,需要將該行的數據進行切分 if (hashline.size()<10) { printf("datasize=%d,data=%s/n",hashline.size(),hashline.c_str()); exit(EXIT_SUCCESS);//換成break的效果呢???是不一樣的啊 } } } return;}void SendHashLine(){ struct msgstrunew_hash_align msgs; int msg_type; char str[80]; int ret_value; int msqid; msqid=msgget(MSGKEY,IPC_EXCL ); /*檢查消息隊列是否存在*/ if(msqid < 0){ msqid = msgget(MSGKEY,IPC_CREAT|0666);/*創建消息隊列*/ if(msqid <0){ printf("failed to create msq | errno=%d [%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } } ifstream m_InStream("hash_list.txt"); string oneline; int running=1; int linenun=0; while (running) { if(!getline(m_InStream, oneline,'/n')) { running = 0; for(int i = 0; i<ChildNum;++i) { msgs.msgtype = linenun; snprintf(msgs.msgtext,sizeof(msgs.msgtext),"%s","nil"); /* 發送消息隊列 */ std::cout<<"task deliver pid="<<getpid()<<","<<msgs.msgtext<<std::endl; ret_value = msgsnd(msqid,&msgs,sizeof(struct msgstrunew_hash_align),0); if ( ret_value < 0 ) { printf("msgsnd() write msg failed,errno=%d[%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } } break;//可以對比下述兩種退出方式 //exit(EXIT_SUCCESS);//EXIT_SUCCESS } linenun++; SplitString(oneline.c_str(),oneline.size(),"/t",scidlist); strncpy(str,oneline.c_str(),80); msgs.msgtype = linenun; strncpy(msgs.msgtext,str,sizeof(msgs.msgtext)); /* 發送消息隊列 */ std::cout<<"task deliver pid="<<getpid()<<","<<msgs.msgtext<<std::endl; int test_len = sizeof(struct msgstrunew_hash_align); ret_value = msgsnd(msqid,&msgs,sizeof(struct msgstrunew_hash_align),0); if ( ret_value < 0 ) { printf("msgsnd() write msg failed,errno=%d[%s]/n",errno,strerror(errno)); exit(EXIT_FAILURE); } }}void MultiOldAligndata_test(){ pid_t fpid; int count=0; fpid=fork(); if (fpid < 0) printf("error in fork!"); else if (fpid == 0) { printf("i am the child process, my process id is %d/n",getpid()); printf("子進程/n"); SendHashLine();//任務分配進程 } else { printf("i am the parent process, my process id is %d/n",getpid()); count++; //基于消息隊列的多進程版本----------begin---------------------------- time_t start,stop; start = time(NULL); int data_processed; string some_data; int i,cpid; // /* create 5 child process */ for (i=0;i<ChildNum;i++){ cpid = fork(); if (cpid < 0) printf("fork failed/n"); else if (cpid ==0) /*child process*/ { childprocnew_hash_test(); } } //需要等待任務分配的進程 int status_1 =0; int mpid_1 =0; mpid_1 = wait(&status_1); int status =0; int mpid =0; for(int i=0;i<ChildNum;i++) { mpid = wait(&status); printf("pid[%d] is exit with status[%d]/n",mpid,status); } stop = time(NULL); std::cout<<"cost:"<<double(stop-start)<<std::endl; //基于消息隊列的多進程版本----------end---------------------------- } // int status_1 =0; // int mpid_1 =0; // mpid_1 = wait(&status_1);//不等待的話??? // sleep(10);//不加sleep操作的話則任務進程會先退出???因為任務進程最先執行結束}
上一篇:tomcat配置編碼格式

下一篇:GCC -D選項

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
国产日韩欧美中文| 欧美日韩免费一区| 欧美小视频在线观看| 亚洲三级av在线| 操91在线视频| 亚洲国产免费av| 国产成+人+综合+亚洲欧美丁香花| 91日韩在线播放| 欧美大学生性色视频| 成人欧美一区二区三区在线湿哒哒| 国产一区欧美二区三区| 国产在线精品自拍| 亚洲一区亚洲二区亚洲三区| 最近日韩中文字幕中文| 欧美视频国产精品| 国产91色在线免费| 91中文在线观看| 欧美亚洲成人免费| 日韩精品电影网| 亚洲r级在线观看| 久久久久久久香蕉网| 97国产一区二区精品久久呦| 中文字幕在线观看亚洲| 欧美大片欧美激情性色a∨久久| 精品亚洲一区二区三区在线观看| 亚洲精品国产美女| 国产欧美亚洲视频| 精品久久久久久久久久久久| 日韩中文有码在线视频| 色99之美女主播在线视频| 国产日韩在线播放| 国产热re99久久6国产精品| 国产精品男人的天堂| 国产精国产精品| 精品久久久国产精品999| 国产午夜精品久久久| 国内成人精品视频| 黑人极品videos精品欧美裸| 国模gogo一区二区大胆私拍| 亚洲精品免费一区二区三区| 国产在线观看91精品一区| 欧美专区中文字幕| 欧美日韩国产在线| 国产一区二区三区在线| 国产精品久久久久久超碰| 91黑丝在线观看| 丝袜亚洲欧美日韩综合| 欧美在线激情网| 精品亚洲一区二区三区| 日韩电影在线观看中文字幕| 国产精品观看在线亚洲人成网| 欧美成人在线网站| 亚洲电影免费观看高清完整版在线| 91网站在线免费观看| 国产91久久婷婷一区二区| 欧美激情在线播放| 日韩高清免费观看| 中文字幕视频在线免费欧美日韩综合在线看| 欧美天天综合色影久久精品| 久久免费国产精品1| 国产亚洲欧美日韩精品| 伊人av综合网| 欧美日韩电影在线观看| 国产亚洲欧洲在线| 中文字幕精品久久久久| 亚洲天堂色网站| 国产最新精品视频| 国产小视频91| 国a精品视频大全| 美女扒开尿口让男人操亚洲视频网站| 日本免费久久高清视频| 亚洲最大的成人网| 日韩欧美视频一区二区三区| 日韩免费观看网站| 日本在线精品视频| 在线观看欧美日韩| 在线视频欧美日韩精品| 国产热re99久久6国产精品| 日韩高清av在线| 日韩欧美在线播放| 欧美一级淫片丝袜脚交| 狠狠操狠狠色综合网| 色香阁99久久精品久久久| 91精品国产色综合久久不卡98| 成人欧美一区二区三区黑人| 亚洲偷欧美偷国内偷| 亚洲欧美日韩一区二区三区在线| 欧美午夜女人视频在线| 91天堂在线视频| 欧美性猛xxx| 午夜精品一区二区三区av| 97超视频免费观看| 日韩大陆欧美高清视频区| 成人午夜激情免费视频| 亚洲欧美日韩国产中文专区| 亚洲国语精品自产拍在线观看| 欧美成人精品一区| 97在线日本国产| 国产精品久久中文| 色综合色综合网色综合| 国产一区二区美女视频| 热久久99这里有精品| 亚洲欧美综合v| 亚洲国产一区二区三区在线观看| 亚洲丝袜av一区| 欧美性猛交xxxx免费看| 日韩成人在线播放| 欧美激情喷水视频| 日韩中文字幕在线视频播放| 国产精品99久久99久久久二8| 91网在线免费观看| 亚洲一区二区三区久久| 久热99视频在线观看| 日韩欧美在线观看| 久久精品视频导航| 在线精品国产欧美| xvideos国产精品| 日韩中文字幕免费视频| 亚洲精品国产综合久久| 亚洲一区久久久| wwwwwwww亚洲| 97精品在线视频| 日韩av影片在线观看| 久久久国产视频91| 欧美华人在线视频| 亚洲成年人在线播放| 欧美人在线视频| 亚洲香蕉成视频在线观看| 欧美成aaa人片在线观看蜜臀| 欧美夫妻性视频| 欧美与欧洲交xxxx免费观看| 精品动漫一区二区| 黑人精品xxx一区一二区| 亚洲一区二区三区sesese| 久久久久久亚洲精品| 亚洲成成品网站| 日韩黄色在线免费观看| 日韩av手机在线观看| 国产精品美女呻吟| 国内精品久久久久久久久| 国产欧美中文字幕| 欧美成年人网站| 国产成人激情小视频| 美日韩精品视频免费看| 亚洲精品一区在线观看香蕉| 成人做爰www免费看视频网站| 亚州成人av在线| 午夜精品一区二区三区av| 国产精品网红直播| 精品少妇一区二区30p| 欧美中文字幕在线视频| 精品女厕一区二区三区| 国产精品美女免费| 91免费精品国偷自产在线| 国产精品永久免费| 91精品国产高清自在线| 在线精品视频视频中文字幕| 欧美在线免费视频| 亚洲a∨日韩av高清在线观看| 成人福利网站在线观看| 成人精品aaaa网站| 国产成人一区二区在线| 日韩国产在线看| 国产精品一二三视频|