当前位置:   article > 正文

(C++通讯架构学习笔记):fork函数详解、范例演示_c++ fork

c++ fork

目录

fork()函数简单认识

僵尸进程的产生、解决,SIGCHLD

fork()函数进一步认识

完善一下fork()代码

fork()失败的可能性

fork()函数简单认识

  • 创建进程
  • 进程的概念:一个可执行程序,执行起来就是一个进程,再执行起来一次,它就又是一个进程(多个进程可以共享同一个可执行文件)。
    • 文雅说法:进程 定义为程序执行的一个实例。
  • 在一个进程(程序)中,可以用fork()创建一个子进程,当该子进程创建时,它从fork()指令的下一条(或者说从fork()的返回处)开始执行与父进程相同的代码。
  • fork()函数产生了一个和当前进程完全一样的新进程,并和当前进程一样从fork()函数里返回。
    • 原来一条执行通路(父进程),现在变成两条(父进程+子进程)

【fork()函数简单范例】

  • fork():一分二
  1. #include <stdio.h>
  2. #include <stdlib.h> //malloc,exit
  3. #include <unistd.h> //fork
  4. #include <signal.h>
  5. //信号处理函数
  6. void sig_usr(int signo)
  7. {
  8. printf("收到了SIGUSR1信号,进程id=%d!\n",getpid());
  9. }
  10. int main(int argc, char *const *argv)
  11. {
  12. pid_t pid;
  13. printf("进程开始执行!\n");
  14. //先简单处理一个信号
  15. if(signal(SIGUSR1,sig_usr) == SIG_ERR) //系统函数,参数1:是个信号,参数2:是个函数指针,代表一个针对该信号的捕捉处理函数
  16. {
  17. printf("无法捕捉SIGUSR1信号!\n");
  18. exit(1);
  19. }
  20. //---------------------------------
  21. pid = fork(); //创建一个子进程
  22. //要判断子进程是否创建成功
  23. if(pid < 0)
  24. {
  25. printf("子进程创建失败,很遗憾!\n");
  26. exit(1);
  27. }
  28. //现在,父进程和子进程同时开始 运行了
  29. for(;;)
  30. {
  31. sleep(1); //休息1秒
  32. printf("休息1秒,进程id=%d!\n",getpid());
  33. }
  34. printf("再见了!\n");
  35. return 0;
  36. }
  • 执行程序:

ps -eo pid,ppid,sid,tty,pgrp,comm,stat | grep -E 'bash|PID|nginx'

  • fork()之后,是父进程fork()之后的代码先执行还是子进程fork()之后的代码先执行是不一定的,这个跟内核调度算法有关。

【发送信号进行测试】

  • 向父进程发送信号

  • 程序收到信号

  • 向子进程发送信号

  • 程序收到信号

【僵尸进程的产生测试】

  • 追踪父进程

  • kill子进程,观察父进程收到什么信号

  • 观察父进程信息

  • 子进程向父进程发送SIGCHLD信号 ,子进程变成了僵尸进程Z

僵尸进程的产生、解决,SIGCHLD

【僵尸进程的产生】

  • 在Unix系统中,一个子进程结束了,但是他的父进程还活着,但该父进程没有调用(wait/waitpid)函数来进行额外的处置,那么这个子进程就会变成一个僵尸进程。
  • 僵尸进程:已经被终止,不干活了,但是依旧没有被内核丢弃掉,因为内核认为父进程可能还需要该子进程的一些信息
  • 作为开发者,坚决不允许僵尸进程的存在。
  • 如何干掉僵尸进程:
    • 重启电脑
    • 手工的把僵尸进程的父进程kill掉,僵尸进程就会自动消失;
    • waitpid():SIGCHLD信号,一个进程被终止或者停止时,这个信号会被发送给父进程。
      • 所以,对于源码中有fork()行为的进程,我们 应该拦截并处理SIGCHLD信号。
  1. #include <stdio.h>
  2. #include <stdlib.h> //malloc,exit
  3. #include <unistd.h> //fork
  4. #include <signal.h>
  5. #include <sys/wait.h> //waitpid
  6. //信号处理函数
  7. void sig_usr(int signo)
  8. {
  9. int status;
  10. switch(signo)
  11. {
  12. case SIGUSR1:
  13. printf("收到了SIGUSR1信号,进程id=%d!\n",getpid());
  14. break;
  15. case SIGCHLD:
  16. printf("收到了SIGCHLD信号,进程id=%d!\n",getpid());
  17. //这里大家学了一个新函数waitpid,有人也用wait,掌握和使用waitpid即可;
  18. //这个waitpid说白了获取子进程的终止状态,这样,子进程就不会成为僵尸进程了;
  19. pid_t pid = waitpid(-1, &status, WNOHANG);
  20. //第一个参数为-1,表示等待任何子进程,
  21. //第二个参数:保存子进程的状态信息(大家如果想详细了解,可以百度一下)。
  22. //第三个参数:提供额外选项,WNOHANG表示不要阻塞,让这个waitpid()立即返回
  23. if(pid == 0) //子进程没结束,会立即返回这个数字,但这里应该不是这个数字
  24. return;
  25. if(pid == -1) //这表示这个waitpid调用有错误,有错误也理解返回出去,我们管不了这么多
  26. return;
  27. //走到这里,表示 成功,那也return吧
  28. return;
  29. break;
  30. } //end switch
  31. }
  32. int main(int argc, char *const *argv)
  33. {
  34. pid_t pid;
  35. printf("进程开始执行!\n");
  36. //先简单处理一个信号
  37. if(signal(SIGUSR1,sig_usr) == SIG_ERR) //系统函数,参数1:是个信号,参数2:是个函数指针,代表一个针对该信号的捕捉处理函数
  38. {
  39. printf("无法捕捉SIGUSR1信号!\n");
  40. exit(1);
  41. }
  42. if(signal(SIGCHLD,sig_usr) == SIG_ERR)
  43. {
  44. printf("无法捕捉SIGCHLD信号!\n");
  45. exit(1);
  46. }
  47. //---------------------------------
  48. pid = fork(); //创建一个子进程
  49. //要判断子进程是否创建成功
  50. if(pid < 0)
  51. {
  52. printf("子进程创建失败,很遗憾!\n");
  53. exit(1);
  54. }
  55. //现在,父进程和子进程同时开始 运行了
  56. for(;;)
  57. {
  58. sleep(1); //休息1秒
  59. printf("休息1秒,进程id=%d!\n",getpid());
  60. }
  61. printf("再见了!\n");
  62. return 0;
  63. }
  • kill子进程

  • 父进程收到信号

fork()函数进一步认识

  • fork()产生新进程的速度非常快,fork()产生的新进程并不复制原进程的内存空间,而是和原进程(父进程)一起共享一个内存空间,但这个内存空间的特性是“写时复制
    • 原来的进程和fork()出来的子进程可以同时、自由的读取内存,但如果子进程(父进程)对内存进行修改的话,那么这个内存就会复制一份给该进程单独使用,以免影响到共享这个内存空间的其他进程使用。
  1. #include <stdio.h>
  2. #include <stdlib.h> //malloc,exit
  3. #include <unistd.h> //fork
  4. #include <signal.h>
  5. int main(int argc, char *const *argv)
  6. {
  7. fork(); //一般fork都会成功所以不判断返回值了,我们假定成功
  8. fork();
  9. for(;;)
  10. {
  11. sleep(1); //休息1秒
  12. printf("休息1秒,进程id=%d!\n",getpid());
  13. }
  14. printf("再见了!\n");
  15. return 0;
  16. }
  • 连续两个fork()形成4个进程

完善一下fork()代码

  • fork()返回两次父进程中返回一次,子进程中返回一次,而且,fork()在父进程中返回的值和在子进程中返回的值是不同的。
    • 子进程的fork()返回值是0。
    • 父进程的fork()返回值是新建立的子进程的ID。
  1. #include <stdio.h>
  2. #include <stdlib.h> //malloc,exit
  3. #include <unistd.h> //fork
  4. #include <signal.h>
  5. int g_mygbltest = 0;
  6. int main(int argc, char *const *argv)
  7. {
  8. pid_t pid;
  9. printf("进程开始执行!\n");
  10. //---------------------------------
  11. pid = fork(); //创建一个子进程
  12. //要判断子进程是否创建成功
  13. if(pid < 0)
  14. {
  15. printf("子进程创建失败,很遗憾!\n");
  16. exit(1);
  17. }
  18. //走到这里,fork()成功,执行后续代码的可能是父进程,也可能是子进程
  19. if(pid == 0)
  20. {
  21. //子进程,因为子进程的fork()返回值会是0;
  22. //这里专门针对子进程的处理代码
  23. while(1)
  24. {
  25. g_mygbltest++; //写时复制,开辟新的内存空间
  26. sleep(1); //休息1秒
  27. printf("真是太高兴了,我是子进程的,我的进程id=%d,g_mygbltest=%d!\n",getpid(),g_mygbltest);
  28. }
  29. }
  30. else
  31. {
  32. //这里就是父进程,因为父进程的fork()返回值会 > 0(实际返回的是子进id程)
  33. //这是专门针对父进程的处理代码
  34. while(1)
  35. {
  36. g_mygbltest++;
  37. sleep(5); //休息5秒
  38. printf("........,我是父进程的,我的进程id=%d,g_mygbltest=%d!\n",getpid(),g_mygbltest);
  39. }
  40. }
  41. return 0;
  42. }
  • 因为全局量g_mygbltest的值发生改变,导致主,子进程内存被单独的分开(写时复制),所以每个的g_mygbltest值也不同。

【一个和fork()执行有关的逻辑判断(短路求值)】

  • ||或:有1出1,全0出0
  • &&与:全1出1,有0出0
((fork() && fork()) || (fork() && fork()));

fork()失败的可能性

  • 系统中进程太多
    • 缺省情况,最大的pid:32767
  • b)每个用户有个允许开启的进程总数
printf("每个实际用户ID的最大进程数=%ld\n",sysconf(_SC_CHILD_MAX));  
  • 输出:7788
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/181123
推荐阅读
相关标签
  

闽ICP备14008679号