Linux 上的两个过滤器通过两个命名管道 (FIFO) 循环链接

Question

我想让两个进程通过 Linux 上的两个命名管道相互通信。 每个进程都是一个 Unix 过滤器：它在其标准输入上读取数据并在其标准输出上写入数据。 它们是循环链接的，因为第一个的输出是第二个的输入，反之亦然。

这是第一个过滤器（ac）的代码：

#include <stdio.h>

int main( void  ){
  FILE* ferr = fopen( "/dev/stderr", "w" );
  double d;

  fprintf(ferr,"A is going to write\n");
  printf("%lf\n",1.);
  fprintf(ferr,"A wrote %lf\n",1.);

  while( 1 ){
    fprintf(ferr,"A is going to read\n");
    if( scanf("%lf",&d) == EOF ){
      break;
    }
    fprintf(ferr,"A recieved : %lf\n",d);
    d += 1;
    fprintf(ferr,"A is going to write\n");
    printf("%lf\n",d);
    fprintf(ferr,"A wrote %lf\n",d);
  }
  return 0;
}

这是第二个过滤器（bc）的代码：

#include <stdio.h>

int main( void  ){
  FILE* ferr = fopen( "/dev/stderr", "w" );
  double d;

  while( 1 ){
    fprintf(ferr,"B is going to read\n");
    if( scanf("%lf",&d) == EOF ){
      break;
    }
    fprintf(ferr,"B recieved : %lf\n",d);
    d += 1;
    fprintf(ferr,"B is going to write\n");
    printf("%lf\n",d);
    fprintf(ferr,"B wrote %lf\n",d);
  }
  return 0;
}

我编译（gcc -o A ac && gcc -o B bc），创建两个 fifo (mkfifo b2a ; mkfifo a2b)，在终端中运行第一个程序 (cat a2b | ./B > b2a)，打开一个新终端并运行第二个程序（cat b2a | ./A > a2b）。

我期望的是一个无限循环，A和B依次增加数字，但我得到的是B卡住了，无法读取A写的内容。

在我启动 B 的术语中，我得到：

B is going to read

在我启动 A 的终端中，我得到：

A is going to write
A wrote 1.000000
A is going to read

如果我使用 lsof：

lsof b2a a2b
COMMAND   PID      USER   FD   TYPE DEVICE SIZE/OFF      NODE NAME
cat     24382 john doe    3r  FIFO   0,22      0t0 282149936 a2b
B       24383 john doe    1w  FIFO   0,22      0t0 282149934 b2a
cat     24413 john doe    3r  FIFO   0,22      0t0 282149934 b2a
A       24414 john doe    1w  FIFO   0,22      0t0 282149936 a2b

为什么我没有得到我期望的结果？

提前致谢。

Answer 1

写入后需要显式fflush，以便输出通过管道。否则，输出可能会保留在写入进程的 stdio 缓冲区中。 （您还可以使用 setvbuf(stdio, NULL, _IONBF, 0) 关闭缓冲。）