进程通信管道问题

popkart718

《unix环境高级编程》403页


明明是两个管道为什么read的时候会发生阻塞呢？请各位大侠指点迷津啊~

a1557664246

新人，学习下

txgc_wm

read依赖于管道的打开模式，打开管道时可使用pipe2设定相应的flags。书上所写的阻塞是在管道中没有数据的情况下发生的。

       int pipe2(int pipefd[2], int flags);

DESCRIPTION
       pipe()  creates  a  pipe, a unidirectional data channel that can be used for interprocess communication.  The array pipefd is used to return
       two file descriptors referring to the ends of the pipe.  pipefd[0] refers to the read end of the pipe.  pipefd[1] refers to the write end of
       the  pipe.  Data written to the write end of the pipe is buffered by the kernel until it is read from the read end of the pipe.  For further
       details, see pipe(7).

       If flags is 0, then pipe2() is the same as pipe().  The following values can be bitwise ORed in flags to obtain different behavior:

       O_NONBLOCK  Set the O_NONBLOCK file status flag on the two new open file descriptions.  Using this flag saves extra  calls  to  fcntl(2)  to
                   achieve the same result.

       O_CLOEXEC   Set  the  close-on-exec  (FD_CLOEXEC) flag on the two new file descriptors.  See the description of the same flag in open(2) for
                   reasons why this may be useful.

同时也可以查看内核文件fs/pipe.c中的pipe_read函数实现。

txgc_wm

使用以下测试程序，便于理解。

测试一：使用pipe2且传入参数的flags为0（相当于使用pipe）

1. #include <unistd.h>
   
2. #include <signal.h>
   
3. #include <string.h>
   
4. #include <stdio.h>
   
5. 
   
6. 
   
7. int fd[2];
   
8. 
   
9. void handle(int sig)
   
10. {
    
11.         if(sig == SIGUSR1)
    
12.                 write(fd[1],"p",1);
    
13. }
    
14. 
    
15. int main(int argc, char **argv)
    
16. {
    
17.         char c;
    
18.         pid_t pid;
    
19.        
    
20.         if(pipe2(fd, 0) < 0) {
    
21.                 printf("can not creat pipe!\n");
    
22.                 return -1;
    
23.         }
    
24.        
    
25.         if((pid = fork()) < 0) {
    
26.                 printf("can not fork!\n");
    
27.                 return -1;
    
28.         } else if(pid > 0) {
    
29.                 close(fd[0]);
    
30.                 signal(SIGUSR1, handle);
    
31.                 for(;;) {
    
32.                 }
    
33.         } else {
    
34.                 close(fd[1]);
    
35.                 for(;;) {
    
36.                         if(read(fd[0], &c, 1) == 1)
    
37.                                 printf("c:%c\n", c);
    
38.                         else
    
39.                                 printf("nothing to read!\n");
    
40. 
    
41.                         sleep(2);
    
42.                 }
    
43.         }
    
44. 
    
45.         return 0;
    
46. }

复制代码

编译后，可以看到程序阻塞在那里，当使用“kill -10 进程号”时，才会从管道中读出数据。


测试二，使用pipe2时设置flags的参数为O_NONBLOCK

1. #include <sys/types.h>
   
2. #include <sys/stat.h>
   
3. #include <fcntl.h>
   
4. #include <unistd.h>
   
5. #include <signal.h>
   
6. #include <string.h>
   
7. #include <stdio.h>
   
8. 
   
9. 
   
10. int fd[2];
    
11. 
    
12. void handle(int sig)
    
13. {
    
14.         if(sig == SIGUSR1)
    
15.                 write(fd[1],"p",1);
    
16. }
    
17. 
    
18. int main(int argc, char **argv)
    
19. {
    
20.         char c;
    
21.         pid_t pid;
    
22.        
    
23.         if(pipe2(fd, O_NONBLOCK) < 0) {
    
24.                 printf("can not creat pipe!\n");
    
25.                 return -1;
    
26.         }
    
27.        
    
28.         if((pid = fork()) < 0) {
    
29.                 printf("can not fork!\n");
    
30.                 return -1;
    
31.         } else if(pid > 0) {
    
32.                 close(fd[0]);
    
33.                 signal(SIGUSR1, handle);
    
34.                 for(;;) {
    
35.                 }
    
36.         } else {
    
37.                 close(fd[1]);
    
38.                 for(;;) {
    
39.                         if(read(fd[0], &c, 1) == 1)
    
40.                                 printf("c:%c\n", c);
    
41.                         else
    
42.                                 printf("nothing to read!\n");
    
43. 
    
44.                         sleep(2);
    
45.                 }
    
46.         }
    
47. 
    
48.         return 0;
    
49. }

复制代码

编译后，执行程序可以看到它不停的打印消息，若管道内没有数据的话，read就直接返回了。

流氓无产者

txgc_wm 发表于 2013-02-28 23:39
read依赖于管道的打开模式，打开管道时可使用pipe2设定相应的flags。书上所写的阻塞是在管道中没有数据的情 ...

windows又如何处理?

txgc_wm

回复 5# 流氓无产者

不知楼主问的东西指的是什么？ windows上的东西我不懂诶。

linux_c_py_php

管道做进程间通信, 两个管道, 一个父到子, 一个子到父.

子阻塞读, 父写1字节唤醒之, 然后父读另一个管道, 然后子写1字节唤醒之.

流氓无产者

txgc_wm 发表于 2013-03-01 09:31
回复 5# 流氓无产者

不知楼主问的东西指的是什么？ windows上的东西我不懂诶。

windows上用pipe处理命令，如何做到异步

popkart718

回复 3# txgc_wm


    有数据的吧，父子进程都往管道里写字符了。

txgc_wm

回复 9# popkart718

你可以用测试例子试试，再看看我说的那个内核文件。