C/C++多进程高并发框架分享【内附可执行源码注释完整】

🚀前言

多进程高并发的设计的思想体现在：电脑物理CPU有多少个核（core）就创建多少个子进程，并且把各个子进程平均分配到各个核（core）上
可以使用下面这个命令看有多少个核（core）👇

cat /proc/cpuinfo
1

因为我这是腾讯云4核8G的服务器，共4个核所以编号是0-1-2-3

由一个master进程进行管理它所生成的几个子进程，然后将几个子进程平均分到各个核（core）中运行

• 优点1：充分利用多核系统的并发处理能力
• 优点2：负载均衡
• 优点3：职责更清晰，工作进程工作，管理进程做管理
  

🍎源码分享

在分享代码前给大家补充几个知识点吧。
1.关于产生子进程的方法大家可以看看这篇博客》》这里这里
2.通过命令ps -ef | grep <你执行的可执行文件>来查看进程状态，并且可以看到他的父子进程关系

3.通过ps -eLo ruser,pid,lwp,psr,args| grep <你执行的可执行文件>来查看进程所属核

---

---

好了来看代码吧（注释都在代码中了，大家有兴趣可以运行一下哦！！）👇
编译命令：

gcc high_concurrency.cpp -o high_concurrency.exe
1

high_concurrency.cpp

#define _GNU_SOURCE
#include 
#include 
#include 
#include 
#include 
#include 
#include 
typedef void (*spawn_proc_pt) (void *data);
static void worker_process_cycle(void *data);
static void start_worker_processes(int n);
pid_t spawn_process(spawn_proc_pt proc, void *data, char *name); 

int main(int argc,char **argv){
    //启动四个工作进程
    start_worker_processes(4);
    //管理子进程，等待子进程结束
    wait(NULL);
}

void start_worker_processes(int n){
    int i=0;
    for(i = n - 1; i >= 0; i--){
       //创建四个子进程（处理任务的过程worker_process_cycle，传入i的地址，名字是work_process）
       spawn_process(worker_process_cycle,(void *)(intptr_t) i, "work_process");
    }
}

pid_t spawn_process(spawn_proc_pt proc, void *data, char *name){

    pid_t pid;
    pid = fork();

    switch(pid){
    case -1:
        fprintf(stderr,"fork() failed while spawning \"%s\"\n",name);
        return -1;
    case 0://如果是子进程
          proc(data);
          return 0;
    default:
          break;
    }
    //pid = fork();会产生两个pid对于子进程来说pid为0（成功的情况下），而父进程则会返回刚刚创建的子进程的pid   
    printf("start %s %ld\n",name,(long int)pid);
    return pid;
}

//设置cpu亲缘关系，把进程绑定在一个cpu的核上面
static void worker_process_init(int worker){
    cpu_set_t cpu_affinity;//cpu亲缘
	//多核高并发处理  4个core  0core-0进程 1core-1进程 2-2 3-3  
    CPU_ZERO(&cpu_affinity);//将结构体清零
    CPU_SET(worker % CPU_SETSIZE,&cpu_affinity);// 0 1 2 3，将核与掩码进行绑定（CPU_SETSIZE为1024） 
    //sched_setaffinity
    //0:绑定自己
    if(sched_setaffinity(0,sizeof(cpu_set_t),&cpu_affinity) == -1){
       fprintf(stderr,"sched_setaffinity() failed\n");
    }
}

void worker_process_cycle(void *data){
    int worker = (intptr_t) data;//worker就是3210
    //初始化，将进程分配给各个核
    worker_process_init(worker);

    //干活，子进程该干什么就写在这下面
    for(;;){
      sleep(10);
      printf("pid %ld ,doing ...\n",(long int)getpid());
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

---

---

🎂总结

其实也没啥好总结的，因为基本上要用到的知识点上面都已经提到了，可以仔细看看这个框架中的注释我相信这样会对你理解代码有很大帮助，大家可以将这个框架保存下来，如果以后需要用的时候就可以参考下这个框架，活学活用，希望这篇文章对您有帮助😀