使用信号进行父子进程同步，对结果重定向后出错。肯请高手解答

j3kljs02398j

问题描述：
使用信号对两个进程进行同步， 正常输出，结果没有问题，但是对输出进行重定向后，结果就错了。

正常输出：

1. $: ./tellwait
   
2. parent        :  1
   
3. child        :  2
   
4. parent        :  3
   
5. child        :  4
   
6. parent        :  5
   
7. child        :  6
   
8. parent        :  7
   
9. child        :  8
   
10. parent        :  9
    
11. child        : 10
    
12. #正常结果应该是父子进程交替对一共享变量加1
    

复制代码

对结果进行重定向：

1. $: /tellwait > tellwait.txt
   
2. $:  cat tellwait.txt
   
3. child        :  2
   
4. child        :  4
   
5. child        :  6
   
6. child        :  8
   
7. child        : 10
   
8. parent        :  1
   
9. parent        :  3
   
10. parent        :  5
    
11. parent        :  7
    
12. parent        :  9
    
13. #重定向后，输出不是交替进行了，why？
    

复制代码

源代码：

1. /*
   
2. * =====================================================================================
   
3. *
   
4. *       Filename:  tellwait.c
   
5. *
   
6. *    Description:  使用信号进行多个进程同步
   
7. *                父子进程交叉对共享变量加一，输出结果
   
8. *
   
9. *        Version:  1.0
   
10. *        Created:  2011年12月06日 10时48分41秒
    
11. *       Compiler:  gcc
    
12. *       Platform:  Linux .6.32-35-generic i686 GNU/Linux
    
13. *
    
14. * =====================================================================================
    
15. */
    
16. #include <assert.h>
    
17. #include <stdio.h>
    
18. #include <unistd.h>
    
19. #include <signal.h>
    
20. #include <sys/mman.h>
    
21. #include <sys/wait.h>
    
22. 
    
23. #define NUM (5 * 2)
    
24. 
    
25. void
    
26. sig_usr(int signo)
    
27. {
    
28.         if (signo == SIGUSR1 || signo == SIGUSR2)
    
29.                 ;
    
30. }
    
31. 
    
32. int main(void)
    
33. {
    
34.         int *shared_p;
    
35.         pid_t pid;
    
36.         int i;
    
37.         struct sigaction act1;
    
38.         struct sigaction act2;
    
39. 
    
40.         /* 捕获SIGUSR1,SIGUSR2 */
    
41.         act1.sa_handler = sig_usr;
    
42.         sigfillset(&act1.sa_mask);
    
43.         act1.sa_flags = 0;
    
44. 
    
45.         act2.sa_handler = sig_usr;
    
46.         sigemptyset(&act2.sa_mask);
    
47.         act2.sa_flags = 0;
    
48. 
    
49.         sigaction(SIGUSR1, &act1, NULL);
    
50.         sigaction(SIGUSR2, &act2, NULL);
    
51. 
    
52.         /* 共享一个一块数据，供父子进程读写 */
    
53.         shared_p = (int *) mmap(NULL, sizeof(int), PROT_READ |PROT_WRITE, MAP_SHARED | MAP_ANONYMOUS, -1, 0);
    
54.         assert(shared_p != NULL);
    
55.         *shared_p = 0;
    
56. 
    
57.         pid = fork();
    
58.         if (pid < 0) {
    
59.                 perror("fork");
    
60.                 return -1;
    
61.         }
    
62.         else if (pid == 0) {
    
63.                 sigset_t set2, old;
    
64.                 /* 子进程收到SIGUSR2信号时对共享变量操作 */
    
65.                 sigemptyset(&set2);
    
66.                 sigaddset(&set2, SIGUSR2);
    
67.                 sigprocmask(SIG_BLOCK, &set2, &old);
    
68.                 sigdelset(&old, SIGUSR2);
    
69. 
    
70.                 for (i = 0; i < NUM / 2; ++i) {/* 简单加1 */
    
71.                         sigsuspend(&old);
    
72.                         (*shared_p)++;
    
73.                         printf("child\t: %2d\n", *shared_p);
    
74.                         kill(getppid(), SIGUSR1);
    
75.                 }
    
76.         }
    
77.         else {
    
78.                 sigset_t set1, old;
    
79. 
    
80.                 /* 父进程收到SIGUSR1信号时对共享变量操作 */
    
81.                 sigemptyset(&set1);
    
82.                 sigaddset(&set1, SIGUSR1);
    
83.                 sigprocmask(SIG_BLOCK, &set1, &old);
    
84.                 sigdelset(&old, SIGUSR1);
    
85.                 for (i = 0; i < NUM / 2; ++i) {/* 简单加1 */
    
86.                         (*shared_p)++;
    
87.                         printf("parent\t: %2d\n", *shared_p);
    
88.                         kill(pid, SIGUSR2);
    
89.                         sigsuspend(&old);
    
90.                 }
    
91.                 wait(NULL);
    
92.                 munmap(shared_p, sizeof (int));
    
93.         }       
    
94.         return 0;
    
95. }

复制代码

djsxut

没有重定向的时候，默认输出到标准输出，是行缓冲的。重定向后，变成了全缓冲。可以在每次printf后面刷新缓冲区，或者改用write。

djsxut

没有重定向的时候，默认输出到标准输出，是行缓冲的。重定向后，变成了全缓冲。可以在每次printf后面刷新缓冲区，或者改用write。

j3kljs02398j

确实如此。非常感谢！