码迷,mamicode.com
首页 > 系统相关 > 详细

一个进程通信的问题

时间:2015-05-10 11:17:36      阅读:161      评论:0      收藏:0      [点我收藏+]

标签:

一、问题的描述如下:

父进程创建子进程1,然后创建子进程2,子进程1将自己的pid乘以2,用可靠信号发送给子进程2,子进程2收到之后,发送给父进程。

二、问题分析:

     首先,进程间发送数据可以用sigaction/sigqueue来完成;可靠信号是kill -l里面 32-64的那些。问题是,子进程1如何知道子进程2的pid?如果知道了,那么这个问题将迎刃而解。

三、问题解决。

      当父进程创建子进程1后,等待,创建子进程2后,父进程将进程2的pid发送给进程1,这样便可以不断的发送数据了。

      代码如下:(子进程会继承父进程注册的信号,所以父进程--子进程1,子进程1-子进程2,子进程2-父进程 的三次发送信号的处理函数都在一开始便进行了注册。)

      

 1 #include <stdio.h>
 2 #include <stdlib.h>
 3 #include <errno.h>
 4 #include <fcntl.h>
 5 #include <unistd.h>
 6 #include <sys/stat.h>
 7 #include <sys/types.h>
 8 #include <sys/types.h>
 9 #include <signal.h>
10 #include <string.h>
11 #include <sys/wait.h>
12 // 要求是子进程1发送给2,但是1如何获得2到pid呢?
13 void handle(int num, siginfo_t * sigdata, void *p)
14 {
15     if(num == SIGRTMIN+1){
16         printf("recv data:%d from pid2\n",sigdata->si_value.sival_int);    
17     }
18     if(num == SIGRTMIN+2){
19         // 收到父进程发过来到信号,解析出pid2,然后把pid*2发送给pid2
20         printf("get pid2` from father %d\n",sigdata->si_value.sival_int);
21         union sigval senddata;
22         senddata.sival_int = getpid()*2;            
23         if(sigqueue(sigdata->si_value.sival_int,SIGRTMIN+3,senddata) == -1){
24             perror("error");
25         }                    
26     }
27     if(num == SIGRTMIN+3){
28         pid_t pid = getppid();
29            union sigval senddata;
30         senddata.sival_int = sigdata->si_value.sival_int;
31         printf("get data %d from pid1\n", senddata.sival_int);
32         if(sigqueue(pid,SIGRTMIN+1,senddata) == -1){
33             perror("error");
34         }
35     }
36 }
37 int main(void)
38 {
39     pid_t pidArray[10] = {0};
40     pid_t pid;
41     int i;
42     struct sigaction sigaf;
43     sigaf.sa_sigaction = handle;        
44     sigaf.sa_flags = SA_SIGINFO;
45     sigaction(SIGRTMIN+1,&sigaf,NULL);
46     
47     sigaction(SIGRTMIN+2,&sigaf,NULL);
48 
49     sigaction(SIGRTMIN+3,&sigaf,NULL);
50     for(i = 0; i < 2; ++i){
51         pidArray[i] = pid = fork();
52         if(pid == 0){
53             break; // 子进程不生子进程
54         }
55         else if(pid > 0){
56         }
57     }
58     if(pid > 0){ // 父进程
59         // 将pid2发送给pid1
60         while(pidArray[2] == 0){
61             
62         }
63         union sigval sendtoone;
64         sendtoone.sival_int = pidArray[1];
65         if(sigqueue(pidArray[0],SIGRTMIN+2,sendtoone) == -1){
66             perror("error");            
67         }
68         sleep(10);
69     }
70 
71     if(pid ==0 && i == 0){ // 子进程1
72         sleep(4);
73         exit(0);
74     }
75     if(pid == 0 && i == 1){ // 子进程2
76         sleep(4);
77         exit(0);
78     }
79     int mypid = 0;
80     while((mypid = waitpid(-1,NULL,WNOHANG)) > 0){
81         printf("%d 结束\n", mypid);
82     }
83     return 0;
84 }

 

一个进程通信的问题

标签:

原文地址:http://www.cnblogs.com/tntboom/p/4491797.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!