0

私は、親が N 個の子プロセスに対して 4 つ接続する割り当てのプログラムを書いています。プログラムはパイプを使用して、プロセス間でゲームの動きを通信します。

ただし、プログラムに存在する競合状態を修正するのに問題があります。ゲームが終了した後、子プロセスがその read() 呼び出しの 1 つをハングする状態があります。これは、複数の子プロセスがある場合にのみ発生するようです。

名前付きセマフォなど、いくつか試してみましたが、フォーク、パイプ、IPC についてはまだ初心者です。関連するコードの要旨をここに投稿しました（読みやすくするために、できる限りクリーンアップしようとしました）：

関連するコードの要旨

どんな助けでも大歓迎です

編集

宣言が追加された要点からの関連ソースを次に示します。

int main (int argc, char const *argv[])
{
  int dimension = 8, children = 2, i;
  int child_play_to_win = 0;
  int fd[children][4];
  pid_t childpid[children];
  Board** boards = (Board**) malloc(sizeof(Board*) * children);
  GameMove* lastMove, *tmpMove;
  char buf[80];
  for(i = 0; i < children; i++) {
     generate_board(&(boards[i]), dimension);
     int tmp[2];
     pipe(tmp);

    // child read
    fd[i][0] = dup(tmp[0]);
    // parent write
    fd[i][1] = dup(tmp[1]);

    pipe(tmp);
    // parent read
    fd[i][2] = dup(tmp[0]);
    // child write
    fd[i][3] = dup(tmp[1]);

        childpid[i] = fork();

    if(childpid[i] == -1) {
        perror("fork");
        exit(1);
    }
    if(childpid[i] == 0) {
      srand(getpid());
      close(fd[i][1]);
      close(fd[i][2]);
      while(!boards[i]->finished) {
        // Read in move from parent
        printf("child[%d] about to read\n", getpid());
        read(fd[i][0], &buf, sizeof(GameMove));

        // repeat parent move on this board

        if(gameNotFinished) {
          // make child move

          // write move back to parent

          write(fd[i][3], lastMove, sizeof(GameMove));

          // If the board is finished (there was a win),
          if (!gameNotFinihsed) {
            // Child wins
            close(fd[i][0]);
            close(fd[i][3]);
            printf("child[%d] ending\n", getpid()); 
            break;
          }
        }
        else {
          // Parent won
          close(fd[i][0]);
          close(fd[i][3]);
          break;
        } 
      }
    dealloc(boards[i]);
    exit(0);
    }
}

  // When this hits children amount, all games are done
  int games_complete = 0;
  // Make first move to all children
  for (i = 0; i < children; i++) {
    close(fd[i][0]);
    close(fd[i][3]);
    lastMove = placePieceAtBestPosition(boards[i], 1);
    printf("parent writing to child[%d]\n", childpid[i]);
    write(fd[i][1], lastMove, sizeof(GameMove));
  }
  while (games_complete != children) {
    for (i = 0; i < children; i++) {
      // Read move from child
      read(fd[i][2], &buf, sizeof(GameMove));

      // repeat child move

      // Check for a child win...
      if (!checkForWin(boards[i], 2)) {
        // No win yet, place piece at best position

        lastMove = placePieceAtBestPosition(boards[i], 1);

        // check for win again
        boards[i]->finished = checkForWin(boards[i], 1);
        // Write move back to child
        write(fd[i][1], lastMove, sizeof(GameMove));

        // If we won, close everything up and increment
        // the games_complete counter.
        if(boards[i]->finished) {
          close(fd[i][1]);
          close(fd[i][2]);
          games_complete++;
        }
      } else {
    // write back child move if there was a win
        write(fd[i][1], lastMove, sizeof(GameMove));
        close(fd[i][1]);
        close(fd[i][2]);
        printf("Parent lost! ):\n");
        games_complete++;
      }
    }
  }
4

1 に答える 1

0

私はあなたの問題が何であるかを知っていると思います。各子をフォークするときは、パイプの親側を閉じます。ただし、各子は、前のすべての子のパイプの親側を開いたままです。このため、最後に作成された子のみがパイプの親側を閉じます。

変更を提案する：

close(fd[i][1]);
close(fd[i][2]);

次のようなものに：

for (j = 0; j <=i; j++) {
  close(fd[j][1]);
  close(fd[j][2]);
}
于 2013-03-06T18:50:06.950 に答える