Linux創建多個子進程并通過捕獲SIGCHLD信號進行非阻塞回收

我們通過fork函數創建多個子進程,并通過exec函數族在子進程中進行其他的工作,但是為了避免僵尸進程,我們要對子進程進行回收。常用的回收方式是wait或者waitpid進行阻塞回收,因為如果非阻塞回收很難把握時機,而阻塞回收將導致父進程無法進行其他的工作。通過子進程狀態改變后會發送一個SIGCHLD信號這一機制,我們可以在父進程中將這一信號進行捕獲然后進行非阻塞的回收子進程并保證能夠回收所有的,也不需要通過sleep函數去強制保證異步。

通過捕獲SIGCHLD信號進行回收子進程最害怕的就是父進程還沒有設置完捕獲函數,子進程全部都死翹翹了,然后父進程就等不到SIGCHLD信號,無法開始回收進程。為了避免這種情況,一般的解決方法是首先對子進程進行一個sleep等待父進程設置捕獲函數,我覺得這種做法十分低效,我想到的解決方式是在fork函數前就對SIGCHLD信號進行屏蔽,等父進程設置好捕獲函數后再解除屏蔽,這樣就不會錯過SIGCHLD信號啦。

另一方面因為未決信號集只是一個簡單的位圖,只能保存有該信號,不能保存該信號發送了多少次,因此我們每次回收進程都要把已經死亡的所有進程進行回收,因為有可能很多子進程一起死亡,這些信號一起發過來,我們不能一個信號只回收一個子進程。

代碼如下:
Utils.h:封裝了一些簡單的操作,簡化代碼,實現放在文末

#ifndef LINUX_UTILS_H
#define LINUX_UTILS_H#include <string>
#include <initializer_list>
#include <signal.h>/*!* 檢查系統調用返回值* @param x 返回值* @param msg 錯誤提示語句* @param y 錯誤狀態,默認為-1*/
bool check_error(int x, const std::string &msg = "error", int y = -1);
/*!* 清零mask,并將il中的信號加入到mask中* @param mask* @param il*/
void add2mask(sigset_t *mask, std::initializer_list<int> il);
/*!* 將il中的信號從mask中刪除* @param mask* @param il*/
void del2mask(sigset_t *mask, std::initializer_list<int> il);/*!* 向阻塞信號集里面添加信號* @param oldset* @param il*/
void add2procmask(std::initializer_list<int> il);/*!*  從阻塞信號集里面刪除信號* @param il*/
void del2procmask(std::initializer_list<int> il);#endif //LINUX_UTILS_H

創建子進程并回收

int &wait_child_num() {static int num = 0;return num;
}void wait_child(int signum) {pid_t pid;int wstatus;while ((pid = waitpid(0, &wstatus, WNOHANG)) > 0) {++wait_child_num();if (WIFEXITED(wstatus)) {cout << "process[" << pid << "] exited with " << WEXITSTATUS(wstatus) << endl;} else {cout << "process[" << pid << "] was terminated by signal " << WTERMSIG(wstatus) << endl;}}
}int test_wait() {int idx;pid_t pid;constexpr int N = 5;/*!* 在fork前應該將SIGALRM信號加入阻塞信號集,否則父進程還沒有來得及設置信號捕捉函數回收子進程,他們全都死亡了,回收了個寂寞*/add2procmask({SIGCHLD});for (idx = 0; idx < N; ++idx) {pid = fork();check_error(pid, "fork error");if (pid == 0)break;}if (idx == N) {//父進程//注冊SIGALRM信號捕捉函數struct sigaction act, oldact;act.sa_flags = 0;add2mask(&act.sa_mask, {SIGINT, SIGQUIT, SIGTSTP});act.sa_handler = wait_child;check_error(sigaction(SIGCHLD, &act, &oldact), "sigaction error");//解除對SIGALRM的屏蔽del2procmask({SIGCHLD});cout << "begin to wait for children" << endl;while (wait_child_num() < N);check_error(sigaction(SIGCHLD, &oldact, nullptr), "sigaction error");} else {my_sleep(idx, 0);}
}

其中mysleep函數是我自己實現的sleep函數,如果有興趣可以看我的另一篇博客:Linux信號實現精確到微秒的sleep函數:通過sigsuspend函數解決時序競態問題

通過wait_child_num返回一個局部靜態變量num引用獲取回收了的子進程的個數,雖然在捕獲函數中使用靜態變量將導致捕獲函數不再是一個可重入函數,但是因為在我的代碼中只有捕獲函數會對num進行寫操作,因此不會發生全局變量異步IO,而且在捕獲信號期間會對SIGCHLD信號屏蔽(通過設置sigaction結構體的sa_flags為0),也不用擔心會發生重入。

之所以將其變成一個局部靜態變量而不是直接使用一個靜態變量是 Effective C++ 條款18:讓接口容易被正確使用的建議,盡可能使用局部靜態變量,因為這樣一方面可以避免名字污染,另一方面可以避免初始化次序問題,當在多個文件中的時候確保使用到該變量時能夠被初始化。

通過測試和查閱APUE,我發現子進程的阻塞信號集和父進程是一致的,但是未決信號集子進程會清零。

Utils.cpp:工具函數的實現,非常簡單

#include "utils.h"using std::string;bool check_error(int x, const string &msg, int y) {if (x == y) {perror(msg.c_str());exit(1);}return true;
}void add2mask(sigset_t *mask, std::initializer_list<int> il) {check_error(sigemptyset(mask), "sigemptyset error");for (auto signum : il) {check_error(sigaddset(mask, signum), "sigaddset error");}
}void del2mask(sigset_t *mask, std::initializer_list<int> il) {for (auto signum : il) {check_error(sigdelset(mask, signum), "sigdelset error");}
}void add2procmask(std::initializer_list<int> il) {sigset_t mask;add2mask(&mask, il);check_error(sigprocmask(SIG_BLOCK, &mask, nullptr), "sigprocmask error");
}void del2procmask(std::initializer_list<int> il) {sigset_t mask;add2mask(&mask, il);check_error(sigprocmask(SIG_UNBLOCK, &mask, nullptr), "sigprocmask error");
}

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/383544.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/383544.shtml
英文地址,請注明出處:http://en.pswp.cn/news/383544.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Linux創建守護進程

守護進程&#xff08;Daemon&#xff09;是運行在后臺的一種特殊進程。它獨立于控制終端并且周期性地執行某種任務或等待處理某些發生的事件。它不需要用戶輸入就能運行而且提供某種服務&#xff0c;不是對整個系統就是對某個用戶程序提供服務。Linux系統的大多數服務器就是通過…

Linux創建多個子線程并回收

創建子線程的邏輯相比子進程要更容易理解一些&#xff0c;因為線程沒有像進程那樣復制很多東西另起爐灶&#xff0c;子線程從傳入的開始函數開始運行&#xff0c;但是難點在于傳入參數和回收時獲取退出狀態&#xff0c;因為這兩個原本都是void *類型的&#xff0c;而我們在使用…

Qt發布程序

Windows&#xff1a; https://www.cnblogs.com/linuxAndMcu/p/10974927.html Ubuntu&#xff1a; https://blog.csdn.net/u014779536/article/details/107854060

K210入門

之前購買了一個Sipeed Maix M1w Dock k210的開發板&#xff0c;想著自己鼓搗鼓搗&#xff0c;在網上看到了一些好的教程&#xff0c;在這里記錄一下&#xff1a; 嵌入式AI從入門到放肆【K210篇】-- 硬件與環境&#xff1a;介紹了各種開發環境的搭建&#xff0c;但是不是特別詳細…

C++輸入輸出:cin/cout 還是 scanf/printf?

相信使用C的人都有一種迷惑或者是不自信&#xff1a;在輸入輸出的時候是不是應該使用scanf/printf更好呢&#xff0c;因為傳說cin/cout龜速&#xff0c;我當時也長期被這個所困擾&#xff0c;后來在閱讀C primer第五版的時候我自己做了一個測試&#xff0c;發現如果不使用std::…

UVA - 101:The Blocks Problem

原本以為是一道很簡單的模擬題&#xff0c;結果寫了一個小時。。。很長時間不碰算法題&#xff0c;的確手感差很多。不過我覺得隨著刷題慢慢多起來應該會好的。 題目的意思也有點含糊&#xff0c;需要自己去猜&#xff0c;大概意思就是槽里有一堆木頭&#xff0c;每個槽剛開始…

UVA - 12096:The SetStack Computer

題目描述很簡單&#xff0c;難點在于如何對集合進行編碼&#xff0c;因為是無限的&#xff0c;好像沒有一個方向進行編碼。 紫書給的題解十分巧妙&#xff1a;給新出現的集合進行編碼 的確&#xff0c;我們沒有必要為所有可能出現的集合編碼后再開始&#xff0c;我們就可以簡單…

UVA - 540:Team Queue

主要的關鍵在于&#xff1a;不要試圖讓所有團隊的人在一個隊列里面&#xff0c;因為這樣如果新入隊的是一個前面團隊的成員則必須先出隊再入隊。 應該把每個團隊看做一個整體&#xff0c;用一個隊列維護團隊的順序&#xff0c;用t個隊列維護每個團隊內部的順序。 還有就是要維…

UVA-136:Ugly Numbers

很簡單的一道題&#xff0c;但是我竟然蠢到想不明白為什么如果從頭生成會出現大量重復的數字。 寫的時候主要出現的錯誤在爆int上&#xff0c;一定要注意數據范圍。 #include <iostream> #include <queue> #include <set>using namespace std; using ll lo…

類的成員函數可以訪問屬于該類的任意對象的私有變量

之前在書上看到成員函數可以訪問類的私有變量的時候覺得是廢話嘛&#xff0c;如果成員函數都不能訪問那私有變量不就變成了花瓶了。然而發現自己還是太naive。 這句話的意思是&#xff1a;在類的作用域內&#xff0c;包含成員函數、靜態成員函數和友元函數內&#xff0c;可以訪…

GMP使用入門

最近寫了一個高精度的模板&#xff0c;想要用GMP庫測試一下&#xff0c;總結一下GMP環境的搭建。 環境搭建&#xff1a;GMP大法教你重新做人(從入門到實戰) 解壓.tar.lz的 時候可能會遇到一點問題&#xff0c;可以參考這個博客&#xff1a;.tar.lz壓縮包解壓 需要注意的是C需要…

UVA - 400:Unix ls

題目的難點在于要求前面的每一列的是最大長度L2&#xff0c;最后一列的長度是L。對于寬度為WIDTH60的一行來說&#xff0c;一行可以放下多少個單詞決定了需要多少行&#xff0c;知道了行數才能開始根據行數開始放置。 我的做法是col (WIDTH 2) / (L 2)&#xff0c;即提前給W…

UVA - 1592:Database

題目的意思是找到兩行在兩列處相等&#xff0c;主要要做的是記錄某個值是否重復出現過。 經過思考&#xff0c;我的思路是&#xff1a;每一列用一個unordered_map<string,vector<int>>記錄單詞出現的行數&#xff0c;對于某一行中的兩列&#xff0c;如果有兩個元素…

C++ array初始化需要雙層大括號

對于array的初始化我們可以使用列表初始化&#xff1a; array<int, 8> test {1,2,3,4,5,6,7,8 };但是當我們不再使用簡單的內置類型array時&#xff1a; array<pair<int, int>, 8> dirs {{-1, -1},{-1, 0},{-1, 1},{0, -1},{0, 1},{1, -1},{1, 0},{1, 1}…

Qt for Android環境配置

最近想寫一個小APP&#xff0c;但是又不想用Android Studio進行開發&#xff0c;想要用C進行開發&#xff0c;聽說Qt可以進行Android開發&#xff0c;就想嘗試一下&#xff0c;結果花了一天時間來配置環境。。。而且發現windows下配置環境更簡單一些&#xff08;我中途還切換到…

UVa-12333:Revenge of Fibonacci 高精度

之前自己仿照紫書上寫了高精度庫&#xff0c;完善了乘法、減法&#xff0c;并且通過了和C高精度庫GMP的對拍測試&#xff0c;并在一些OJ上過了一些高精度的模板題&#xff0c;代碼倉庫地址&#xff1a;https://github.com/Edward-Elric233/BigInt 求解思路 題目的意思是求前1…

vim命令筆記

vim折疊函數&#xff1a;https://www.cnblogs.com/zlcxbb/p/6442092.html Vim錄制宏及使用&#xff1a;https://www.jianshu.com/p/9d999c72a9f3 將vim與系統剪貼板的交互使用&#xff1a;https://zhuanlan.zhihu.com/p/73984381

Educational Codeforces Round 114總結

緒論 https://codeforces.com/contest/1574/ 以前想要打CF&#xff0c;總是覺得沒有時間&#xff0c;要做這個&#xff0c;要做那個&#xff0c;現在時間充裕了一些&#xff0c;想要多打一些CF&#xff0c;但是光打比賽不總結是沒有什么幫助的&#xff0c;這是我從以前的ACM訓…

UVA - 210:Concurrency Simulator

題目鏈接&#xff1a;https://vjudge.net/problem/UVA-210 題目分析 就是一道模擬題&#xff0c;但是細節有點多。 寫代碼兩個小時&#xff0c;調試代碼用了兩天。。。很長時間不刷題了&#xff0c;這道雖然算法簡單但是細節滿滿的題目對我來說是一個很好的熱身。 盡量不要去…

UVA - 514:Rails

題目鏈接&#xff1a;https://vjudge.net/problem/UVA-514 題目分析 題目的意思是給一個棧輸入一系列數據&#xff0c;在這個過程中可以出棧&#xff0c;看能否達到某個結果。 剛開始我覺得這個情況好多&#xff0c;因此不是用模擬&#xff0c;而應該觀察結果本身。對于結果中…