プロセスが読み取りでハングする

Question

次のコードは、パイプを通じて他のプロセスからのメッセージを読み取ります。すべてのプロセスがすべてのメッセージを正しく出力しますが、whileループを過ぎることはありません。 Eclipseでデバッグを試みましたが、すべてのメッセージを読んだ後、ループ中に停止します。

インデックスは、各プロセスに割り当てられた番号です。最初のプロセスはインデックス== 0を持ちます。 メッセージ自体は単にメッセージを送信するプロセスのインデックスです。

while((n = read(fd[index][0], &mymsg, sizeof(int))) == sizeof(int)) 
     printf("process%d has received a message from process%d\n", index, mymsg); 

これはどうなるのでしょうか？

// Write to other process 
if(write(fd[index2][1], &index, sizeof(int)) != sizeof(int)) 
    sys_error(2); 

これが5回行われます。ここでは

は、各プロセスが別のものに書き込む方法です。 fdは各プロセスの読み書き終了の表です。

Answer 1

さらにデータが表示されるまで、read()の呼び出しがブロックされています。 man page for pipe

からプロセスデータが利用可能になるまで、（2）意志 ブロックを読み取り、その後、空のパイプから読み取ろうとした場合。プロセスが フル・パイプ（以下を参照）に書き込もうとすると、書き込みが完了するのに十分なデータがパイプから読み取られるまでブロックを書き込みます（2）。ノンブロッキング fcntl（2）F_SETFL操作を使用して、O_NONBLOCKオープンファイルステータスフラグ を有効にすると、I/Oを実行できます。

しばらくループがそれぞれにこれを行うことを入力する前に、各ファイルディスクリプタを開いた後：

fcntl(fd, F_SETFL, O_NONBLOCK); 

しかし、あなたが本当に含めて、非ブロックI/O対ブロック上に読んでくださいread、fcntlなどのマニュアルページを読んでください。