参考:linux管道pipe详解 注意 当fork 创建子进程也会把 pipe 复制下来
#include <stdio.h>
#include <unistd.h>
#include <sys/wait.h>
#include <string.h>
#include <stdlib.h>
int main(void)
{
pid_t pid;
int fd[2], i, n;
char buf[1024];
int ret = pipe(fd);
if(ret == -1){
perror("pipe error");
exit(1);
}
for(i = 0; i < 3; i++){
if((pid = fork()) == 0)
break;
else if(pid == -1){
perror("pipe error");
exit(1);
}
}
if (i == 0) {
close(fd[0]);
write(fd[1], "1.hello\n", strlen("1.hello\n"));
} else if(i == 1) {
close(fd[0]);
write(fd[1], "2.world\n", strlen("2.world\n"));
} else if(i == 2) {
close(fd[0]);
printf("333333333333\n");
write(fd[1], "3.xixixixi\n", strlen("3.xixixixi\n"));
} else {
close(fd[1]);
for(i = 0; i < 3; i++)
wait(NULL);
n = read(fd[0], buf, 1024);
write(STDOUT_FILENO, buf, n);
}
return 0;
}
|