c - 通过管道从多个子进程写入父进程

Question

这是我针对这种情况的代码。基本上，我有很多 child ，他们应该从 ptList 中计算出一定数量的点，将各自的点传递给 parent ，然后 parent 将它们加起来。不幸的是，在我的 printfs 中，“addToTotal”变量没有更新超过第一个 child ，我的回答是不正确的。任何建议都会令人难以置信。

pid_t worker[ workers ];
for (int i = 0; i < workers; i++) {
//printf( "I am child %i\n", i );
if ((worker[i] = fork()) < 0) {
   fail( "Can't create child");
} else if ( worker[i] == 0) {
   //Close the reading end of the pipe for each child
   close( pfd[0] );

   // Get each of the workers to compare points
   for ( int k = i; k < ptCount; k += workers ) {
      for ( int j = k + 1; j < ptCount; j++) {
        int dx = ptList[ k ].x - ptList[ j ].x;
        int dy = ptList[ k ].y - ptList[ j ].y;
        if ( dx * dx + dy * dy <= dsq )
           childTotal++;
      }
   }
   printf( "Child %i total: %i\n", i, childTotal );
   lockf( pfd[ 1 ], F_LOCK, 0 );
   write( pfd[ 1 ], &childTotal, sizeof( childTotal ));
   lockf( pfd[ 1 ], F_ULOCK, 0 );
   close( pfd[ 1 ] );
   exit(0);
   wait(NULL);
}
wait(NULL);
close( pfd[ 1 ] );
read( pfd[ 0 ], &addToTotal, sizeof( addToTotal ) );
printf( "AddToTotal: %i\n", addToTotal );
total += addToTotal;
}

Answer 1

child 得到一个写端关闭的管道，因为你在行中明确地关闭了它:

close( pfd[ 1 ] );

然后在下一次迭代中您尝试再次写入管道:

write( pfd[ 1 ], &childTotal, sizeof( childTotal ));