#include
#include
int pid1, pid2; // 定义两个进程变量
main( ) {
int fd[2];
char OutPipe[100], InPipe[100]; // 定义两个字符数组
pipe(fd); // 创建管道
while ((pid1 = fork( )) == -1); // 如果进程1创建不成功,则空循环
if (pid1 == 0)
{ // 如果子进程1创建成功,pid1为进程号
lockf(fd[1], 1, 0); // 锁定管道
sprintf(OutPipe, "\n Child process 1 is sending message!\n"); // 给Outpipe赋值
write(fd[1], OutPipe, 50); // 向管道写入数据
sleep(5); // 等待读进程读出数据
lockf(fd[1], 0, 0); // 解除管道的锁定
exit(0); // 结束进程1
}
else {
while ((pid2 = fork()) == -1); // 若进程2创建不成功,则空循环
if (pid2 == 0)
{
lockf(fd[1], 1, 0);
sprintf(OutPipe, "\n Child process 2 is sending message!\n");
write(fd[1], OutPipe, 50);
sleep(5);
lockf(fd[1], 0, 0);
exit(0);
}
else {
wait(0); // 等待子进程1 结束
read(fd[0], InPipe, 50); // 从管道中读出数据
printf("%s\n", InPipe); // 显示读出的数据
wait(0); // 等待子进程2 结束
read(fd[0], InPipe, 50);
printf("%s\n", InPipe);
exit(0); // 父进程结束
}
}
}
ly_chaojilong 于 2009-09-08 13:20:18发表:
收藏了。。。Thanks.
xiazhouquan 于 2009-09-08 12:02:15发表:
再在学习，谢谢
jssjjsnt 于 2006-08-08 12:36:37发表:
呵呵