管道的问题(写的非原子性)

天外飞客

书上的一个例子:

#include <unistd.h>
#include <sys/types.h>
#include <errno.h>
#include <limits.h>
                                                                                
int main()
{
        int pipe_fd[2];
        pid_t pid;
        char r_buf[4096];
        char w_buf[4096*2];
        int writenum;
        int rnum=1;
        memset(r_buf,0,sizeof(r_buf));
        if(pipe(pipe_fd)<0)
        {
        printf("pipe error\n");
        return -1;
        }
        if((pid=fork())==0)//进入子进程
        {
        close(pipe_fd[1]);//关闭写
        while(rnum!=0)
        {
        sleep(1);
        rnum=read(pipe_fd[0],r_buf,1000);
        printf("child readnum is %d\n",rnum);
        }
        close(pipe_fd[0]);//关闭读
        exit(0);//子进程退出
        }
        else if(pid>0)//父进程
        {
        close(pipe_fd[0]);
        memset(r_buf,0,sizeof(r_buf));
        if((writenum=write(pipe_fd[1],w_buf,1024))==-1)
                printf("write to pipe error\n");
        else
                printf("the bytes write to pipe is %d \n",writenum);
        writenum=write(pipe_fd[1],w_buf,4096);
        close(pipe_fd[1]);
        }
        return 0;
}
运行结果:
[root@localhost work]# ./demo
the bytes write to pipe is 1024
child readnum is 1000
[root@localhost work]# child readnum is 1000
child readnum is 1000
child readnum is 1000    此行为什么说明了写入的非原子性?
child readnum is 1000
child readnum is 120   此行为什么说明了写入的非原子性?
child readnum is 0

我的系统为redhat 9.0...PIPE_BUF为4096字节
请高手回答.


[ 本帖最后由 天外飞客 于 2007-4-26 18:09 编辑 ]

flw2

代码太长了。

天外飞客

这代码也长呀..
只是把字放大了点呀

MMMIX

原帖由 天外飞客 于 2007-4-26 12:19 发表
这代码也长呀..
只是把字放大了点呀

关键是你干吗要把字放大？这样看着真的很费劲。

goooogo

我仔细看了代码，分析一下。见程序中的注释。

1. 
   
2. #include <unistd.h>
   
3. #include <sys/types.h>
   
4. #include <errno.h>
   
5. #include <limits.h>
   
6.                                                                                 
   
7. int main()
   
8. {
   
9.         int pipe_fd[2];
   
10.         pid_t pid;
    
11.         char r_buf[4096];
    
12.         char w_buf[4096*2];
    
13.         int writenum;
    
14.         int rnum=1;
    
15.         memset(r_buf,0,sizeof(r_buf));
    
16.         if(pipe(pipe_fd)<0)
    
17.         {
    
18.         printf("pipe error\n");
    
19.         return -1;
    
20.         }
    
21.         if((pid=fork())==0)//进入子进程
    
22.         {
    
23.         close(pipe_fd[1]);//关闭写
    
24.         while(rnum!=0)
    
25.         {
    
26.         sleep(1);
    
27.         rnum=read(pipe_fd[0],r_buf,1000);
    
28.         printf("child readnum is %d\n",rnum);
    
29.         }
    
30.         close(pipe_fd[0]);//关闭读
    
31.         exit(0);//子进程退出
    
32.         }
    
33.         else if(pid>0)//父进程
    
34.         {
    
35.         close(pipe_fd[0]);
    
36.         memset(r_buf,0,sizeof(r_buf));
    
37.         if((writenum=write(pipe_fd[1],w_buf,1024))==-1)
    
38.                 printf("write to pipe error\n");
    
39.         else
    
40.                 printf("the bytes write to pipe is %d \n",writenum);
    
41.         writenum=write(pipe_fd[1],w_buf,4096);
    
42.         close(pipe_fd[1]);
    
43.         }
    
44.         return 0;
    
45. }
    
46. 运行结果:
    
47. [root@localhost work]# ./demo
    
48. the bytes write to pipe is 1024
    
49. child readnum is 1000
    
50. [root@localhost work]# child readnum is 1000
    
51. child readnum is 1000
    
52. child readnum is 1000    此行为什么说明了写入的非原子性?  //这个地方不知道为什么
    
53. child readnum is 1000
    
54. child readnum is 120   此行为什么说明了写入的非原子性?    //此地方当然证明了写入的非原子性，因为非原子性表示写入可能不会一次完成，也就是可以阻塞的。这个地方由于PIPI_BUF是4096，所以，你再次写入4096的时候，PIPE已经满了，所以，这个地方要阻塞，等待读PIPE到来，读取之后，才能再往里边写。
    
55. child readnum is 0
    
56. 
    

复制代码

天外飞客

现在可以了吧?
谁给解释下啊.谢谢啦

goooogo

原帖由 天外飞客 于 2007-4-26 18:10 发表
现在可以了吧?
谁给解释下啊.谢谢啦

晕。上边不是已经给了解释么？？？

天外飞客

解释有点问题的~~没解释完啊.

天外飞客

看了其他的参考..
写4096下的是原子性的,不过这个原子是可以分2段的..还是1次..
最后还是没明白

goooogo

原帖由 goooogo 于 2007-4-26 13:13 发表
我仔细看了代码，分析一下。见程序中的注释。
[code]
#include <unistd.h>
#include <sys/types.h>
#include <errno.h>
#include <limits.h>
                                    ...

试了一下代码，好像一次写入>4096也可以。
这个真是不好解释。