1

在我的程序中，我创建了 3 个子进程，然后分配它们执行相同的操作，即减少一个数字。当数字=0时程序停止。我使用 2 个管道在父进程和子进程之间进行通信。

int  a;
int main(void)
{

a=10;
//declare and create 2 pipes
int p1[2], p2[2];
pipe(p1);
pipe(p2);
    int ra;
for(int i=0;i<3;i++)
{   
    pid=fork();
    if(pid==0) 
    {
        close(p1[1]);
        close(p2[0]);
        read(p1[0],&ra,3);

        while(ra>0)
        {

            ra-=1;
            printf("%i a are available, reported by process %i\n",ra,getpid());
            close(p1[0]);
            write(p2[1],&ra,3);

            close(p2[1]);

        }
        break;

    }
    else
    if(pid>0)
    {


    }else
    {
        wait(NULL);

    }

}
  }
 if(pid>0)
{
        close(p1[0]);
        close(p2[1]);
        if(a>0)
        {
            write(p1[1],&a,3);
            close(p1[1]);
        }
        else
            exit(0);
        read(p2[0],&ra,3);
        a=ra;
        close(p2[0]);


}

我的问题是只有一个子进程在运行并减少一个值，直到 a=0。其他进程没有机会。我该如何解决？预先感谢

4

1 回答 1

1

您希望在循环的每次迭代中从父级读取每个子块。例如，子代码应该是这样的：

while( read( p1[0], &a, sizeof a ) == sizeof a ) {
  a -= 1;
  write( p2[1], &a, sizeof a );
}

父代码应如下所示：

do {
    write( p1[1], &a, sizeof a );
} while( read( p2[0], &a, sizeof a ) == sizeof a && a > 0 );
close( p1[1] );

这使得每个子在递减计数器后阻塞读取，从而进入睡眠直到父被调度。在父级将值写入适当的管道后，只有一个阻塞读取的子级将被唤醒以递减计数器。

于 2013-10-15T04:48:55.203 回答