为了更好的理解管道的读与写,请看下面的一段程序:
#include
#include
#include
#include
#include
int main()
{
int pipe_fd[2];
pid_t pid;
char buf_r[100];
char *p_wbuf;
int r_num;
memset(buf_r,0,sizeof(buf_r));//把一段内存清0
if(pipe(pipe_fd)<0)//创建管道
{
printf("pipe create error\n");
return -1;
}
if((pid=fork())==0)//创建一子进程,如果子进程先运行
{
printf("\n");
close(pipe_fd[1]);//关闭子进程写描述符,并通过使父进程暂停2s确保
//父进程已关闭相应的读描述符
sleep(2);
if((r_num=read(pipe_fd[0],buf_r,100))>0)//子进程读取管道内容
{
printf("%d numbers read from the pipe is %s\n",r_num,buf_r);
}
close(pipe_fd[0]);//关闭子进程读描述符
exit(0);
}
else if(pid>0)//如果父进程先运行
{
close(pipe_fd[0]);//关闭父进程读描述符,并分两次向管道中写入hello pipe
if(write(pipe_fd[1],"hello",5)!=-1)
{
printf("parent write1 success !\n");
}
if(write(pipe_fd[1],"pipe",5)!=-1)
{
printf("parent write2 sucess !\n");
}
close(pipe_fd[1]);//关闭父进程写描述符
sleep(3);
waitpid(pid,NULL,0);//收集子进程退出信息
exit(0);
}
}
/*--------------------------------------------------------
notes:
1.用pipe函数创建的管道两端处于一个进程中,实际上,通常先是创建一个管道,再
通过fork()函数创建一子进程,该子进程会继承父进程所创建的管道。
2.实验:
[root@localhost the_eight_step]# gcc pipe_rw.c -o pipe_rw
[root@localhost the_eight_step]# ./pipe_rw
parent write1 success !
parent write2 sucess !
10 numbers read from the pipe is hellopipe
3.管道读写注意点
.只有在管道的读写端存在时向管道中写入数据才有意义。否则,向管道中写入数据的进程
将收到内核传来的SIFPIPE信号(通常Broken pipe错误)。
.向管道中写入数据时,linux将不保证写入的原子性,管道缓冲区有一空闲区域,写进程就
会试图向管道写入数据。如果读进程不读取管道缓冲区中的数据,那么写操作将会一直阻塞。
.父子进程在运行时,它们的先后次序并不能保证,因此,在这里为了保证父进程已经关闭了
读描述符,可在子进程中调用sleep函数。
4.主要顺序:
先创建管道,后创建子进程
-------------------------------------------------------------*/
阅读(1141) | 评论(1) | 转发(0) |