linux中的一个简单的多进程程序.输入一些数字,如./findPrime 102030。该程序将创建3个子进程,以查找2-10、10-20、20-30之间的所有素数。一旦子进程找到了一个素数,它就会通过管道写出"2是质数“并发送给父进程。父级将在屏幕上打印。这里的问题是,我使用一个while循环将消息写到管道中,并在父端使用另一个while循环来接收消息,但是下面的代码只显示第一条消息,所以我想知道发生了什么,我如何继续从管道中读取消息呢?我错过了什么吗?非常感谢!
char readBuffer[100];
char outBuffer[15];
int pids[argc];
int fd[2];
pipe(fd);
for(i = 0; i < argc; i++)
{
if( i == 0)
bottom = 2;
else
bottom = args[i - 1];
top = args[i];
pids[i] = fork();
if(pids[i] == 0)
{
printf("Child %d: bottom=%d, top=%d\n", getpid(), bottom, top);
close(fd[0]);
j = bottom;
while(j <= top)
{
int res = findPrime(j);
if(res == 1)
{
sprintf(outBuffer, "%d is prime", j);
write(fd[1], outBuffer, (strlen(outBuffer)+1));
}
j++;
}
exit(0x47);
}
else if(pids[i] < 0)
{
fprintf(stderr, "fork failed! errno = %i\n", errno);
break;
}
else
{
close(fd[1]);
while((nbytes = read(fd[0], readBuffer, sizeof(readBuffer))) > 0 )
printf("%s\n", readBuffer);
int status = 0;
pid = waitpid(pids[i], &status, 0);
if(pid >= 0)
printf("Child %d exited cleanly\n", pid);
}
}这些子进程应该按照创建的顺序运行,就像进程1完成时,进程2将运行,进程3将在2之后运行。我还希望父进程在收到消息时立即显示消息。
发布于 2013-09-23 03:01:37
在fork时,父/子共享他们的文件描述符(现在是这样)。您当前的问题是关闭父级中的fd1。当第一个子进程结束时,进程结束的事实意味着fd1将在子进程中自动关闭。由于操作系统不再具有对文件描述符的任何有效引用,它将变得无效。因此,您的管道写入失败的所有后续的孩子。
所以,不要关闭父级中的fd1。
但你也有其他问题。一个跳出的问题是,如果您的一个子进程找不到质数,它就永远不会写到管道中。然而,父母将永远阻止等待永远不会到达的读物。如果不关闭父文件中的fd1,您将不会在父文件中看到EOF -即读取() == 0。因此,一种解决方案是通过管道传递一条“完成”消息,并让父解析出该消息。
一个更好的解决方案是考虑重新设计。通过解析程序开始时的命令行参数来计算您需要的进程数。然后,动态地为您需要的管道描述符的数量分配空间,并为每个进程提供自己的一对。这可以完全避免任何事情,是一种更标准的做事方式。
https://stackoverflow.com/questions/18950398
复制相似问题