使用信號進(jìn)行父子進(jìn)程同步，對結(jié)果重定向后出錯(cuò)�？险埜呤纸獯�

j3kljs02398j

問題描述：
使用信號對兩個(gè)進(jìn)程進(jìn)行同步， 正常輸出，結(jié)果沒有問題，但是對輸出進(jìn)行重定向后，結(jié)果就錯(cuò)了。

正常輸出：

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. #正常結(jié)果應(yīng)該是父子進(jìn)程交替對一共享變量加1
    

復(fù)制代碼

對結(jié)果進(jìn)行重定向：

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. #重定向后，輸出不是交替進(jìn)行了，why？
    

復(fù)制代碼

源代碼：

1. /*
   
2. * =====================================================================================
   
3. *
   
4. *       Filename:  tellwait.c
   
5. *
   
6. *    Description:  使用信號進(jìn)行多個(gè)進(jìn)程同步
   
7. *                父子進(jìn)程交叉對共享變量加一，輸出結(jié)果
   
8. *
   
9. *        Version:  1.0
   
10. *        Created:  2011年12月06日 10時(shí)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.         /* 共享一個(gè)一塊數(shù)據(jù)，供父子進(jìn)程讀寫 */
    
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.                 /* 子進(jìn)程收到SIGUSR2信號時(shí)對共享變量操作 */
    
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.                 /* 父進(jìn)程收到SIGUSR1信號時(shí)對共享變量操作 */
    
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. }

復(fù)制代碼

djsxut

沒有重定向的時(shí)候，默認(rèn)輸出到標(biāo)準(zhǔn)輸出，是行緩沖的。重定向后，變成了全緩沖�？梢栽诿看蝡rintf后面刷新緩沖區(qū)，或者改用write。

djsxut

沒有重定向的時(shí)候，默認(rèn)輸出到標(biāo)準(zhǔn)輸出，是行緩沖的。重定向后，變成了全緩沖�？梢栽诿看蝡rintf后面刷新緩沖區(qū)，或者改用write。

j3kljs02398j

確實(shí)如此。非常感謝！