为什么两个进程，只有一个进程在运行，另外一个进程感觉从来没有跑过

hmchzb19

代码如下：

1. #include <apue.h>
   
2. #include <sys/wait.h>
   
3. #include <unistd.h>
   
4. #include <limits.h>
   
5. #include <fcntl.h>
   
6. 
   
7. 
   
8. #define READ_FD 0
   
9. #define WRITE_FD 1
   
10. #define RD_CHUNK 10
    
11. #define ATOMIC
    
12. 
    
13. #ifndef PIPE_BUF
    
14.     #define PIPE_BUF _POSIX_PIPE_BUF
    
15. #endif
    
16. 
    
17. void do_nothing(int signo)
    
18. {
    
19.     return ;
    
20. }
    
21. 
    
22. int main(int argc, char *argv[])
    
23. {
    
24.     int i,repeat;
    
25.     int bytesread;
    
26.     int mssglen;
    
27.     pid_t child1, child2;
    
28.     int fd[2];
    
29.     int outfd;
    
30. 
    
31.     char message[RD_CHUNK + 1];
    
32.     char *Child1_Chunk, *Child2_Chunk;
    
33.     long Chunk_Size;
    
34. 
    
35.     static struct sigaction sigact;
    
36. 
    
37.     sigact.sa_handler=do_nothing;
    
38.     sigfillset(&(sigact.sa_mask));
    
39.     sigaction(SIGUSR1, &sigact, NULL);
    
40. 
    
41.     //check argc
    
42.     if( argc < 2){
    
43.         fprintf(stderr,"Usage: %s size \n",argv[0]);
    
44.         exit(1);
    
45.     }
    
46. 
    
47.     //try to create pipe
    
48.     if(-1 == pipe(fd)){
    
49.         perror("pipe call");
    
50.         exit(2);
    
51.     }
    
52. 
    
53.     repeat=atoi(argv[1]);
    
54. 
    
55. #ifdef ATOMIC
    
56.     Chunk_Size = PIPE_BUF;
    
57. #else
    
58.     Chunk_Size = PIPE_BUF + 200;
    
59. #endif
    
60.     printf("Chunk size =%ld\n",Chunk_Size);
    
61.     printf("Value of PIPE_BUF is %ld\n",PIPE_BUF);
    
62.     Child1_Chunk=calloc(Chunk_Size,sizeof(char));
    
63.     Child2_Chunk=calloc(Chunk_Size,sizeof(char));
    
64.     if((NULL == Child1_Chunk) ||(NULL == Child2_Chunk)){
    
65.         perror("calloc");
    
66.         exit(2);
    
67.     }
    
68. 
    
69.     //create the string that child1 writes
    
70.     Child1_Chunk[0] = '\0';     //just to be safe
    
71.     for(i=0; i < Chunk_Size -2; i++)   
    
72.         strcat(Child1_Chunk,"X");
    
73.     strcat(Child1_Chunk,"\n");
    
74. 
    
75.     //create the string that child2 writes
    
76.     Child2_Chunk[0]='\0';       //just to be safe
    
77.     for(i=0;i<Chunk_Size -2;i++)
    
78.         strcat(Child2_Chunk,"y");
    
79.     strcat(Child2_Chunk,"\n");
    
80. 
    
81.     //create first child process
    
82.     switch(child1 = fork()){
    
83.         case -1:            //fork failed -- exit
    
84.             perror("fork()");
    
85.             exit(3);
    
86. 
    
87.         case 0:             //child1 code
    
88.             mssglen=strlen(Child1_Chunk);
    
89.             pause();
    
90.             sleep(5);
    
91.             for(i=0;i<repeat;i++){
    
92.                 if(write(fd[WRITE_FD],Child1_Chunk,mssglen)!= mssglen){
    
93.                     perror("write");
    
94.                     exit(4);
    
95.                 }
    
96.             }
    
97.             close(fd[WRITE_FD]);
    
98.             exit(0);
    
99. 
    
100.         default:        //parent creates second child process
     
101.             switch(child2 = fork()){
     
102.                 case -1:        //fork failed --exit
     
103.                     perror("fork()");
     
104.                     exit(5);
     
105. 
     
106.                 case 0:         //child2 code
     
107.                     mssglen=strlen(Child2_Chunk);
     
108.                     pause();
     
109.                     for(i=0;i<repeat;i++){
     
110.                         if(write(fd[WRITE_FD],Child2_Chunk,mssglen)!= mssglen){
     
111.                             perror("write");
     
112.                             exit(6);
     
113.                         }
     
114.                     }
     
115.                     close(fd[WRITE_FD]);
     
116.                     exit(0);
     
117. 
     
118.                 default:        //parent code
     
119.                     outfd=open("pd2_output",O_WRONLY|O_CREAT|O_TRUNC,0644);
     
120.                     if(-1==outfd){
     
121.                         perror("open");
     
122.                         exit(7);
     
123.                     }
     
124.                     close(fd[WRITE_FD]);
     
125.                     kill(child2,SIGUSR2);
     
126.                     kill(child1,SIGUSR1);
     
127.                     while((bytesread = read(fd[READ_FD],message,RD_CHUNK))!=0)
     
128.                         if(bytesread >0 ){          //more data
     
129.                             write(outfd,message,bytesread);
     
130.                         }
     
131.                         else{
     
132.                             perror("read() ");
     
133.                             exit(8);
     
134.                         }
     
135.                     close(outfd);
     
136.                     //collect zombies
     
137.                     for(i=1;i<=2;i++)
     
138.                         if(wait(NULL)==-1){
     
139.                             perror("wait failed");
     
140.                             exit(9);
     
141.                         }
     
142.                         close(fd[READ_FD]);
     
143.                         free(Child1_Chunk);
     
144.                         free(Child2_Chunk);
     
145.                     }
     
146.                     exit(0);
     
147.             }
     
148.     }
     

复制代码

我看过pd2_output,里面全是X，没有y，也就是说child2 从来没有机会跑过。
为什么呢？

gkmail

                    kill(child2,SIGUSR2);
这里写的有问题，应该是kill(child2,SIGUSR1). SIGUSR2没有注册handler,这里把child2杀死了。

hmchzb19

怪不得啊，我这才发现，多谢。