在Linux中读写PIPE

Question

linux中一个简单的多进程程序.输入一些数字,如./findPrime 10 20 30.该程序将创建3个子进程,以找出2-10,10-20,20-30之间的所有素数.一旦子进程找到一个素数,它将通过管道写入"2 is prime"并发送给父进程.家长会在屏幕上打印出来.问题在于,我使用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之后运行.我还希望父进程在收到消息时立即显示消息.

Answer 1

父/子共享他们的文件描述符(就像他们现在一样)fork.你当前的问题是你关闭了父母的fd [1].当第一个孩子结束时,过程结束的事实意味着fd [1]将在孩子中自动关闭.由于操作系统不再具有对文件描述符的任何有效引用,因此它将变为无效.因此,您的管道写入会在所有后续子项中失败

所以不要在父母中关闭fd [1].

但是你也有其他问题.一个跳出的是,如果你的其中一个子进程不找到一个黄金永远不会写到管道.然而,父母将永远阻止等待阅读的东西永远不会到来.通过不关闭父级中的fd [1],您将看不到EOF - 即父级中的read()== 0.因此,一种解决方案是通过管道传回"完成"消息,并让父解析完成.

更好的解决方案是考虑重新设计.通过在程序开头解析命令行参数来计算您将需要的进程数.然后为您将需要的管道描述符的数量动态分配空间,并为每个进程分配自己的对.这可以完全避免一切,是一种更标准的做事方式.