c - C使用select()从两个命名管道(FIFO)中读取

我目前正在尝试用C编写一个程序，它将从两个命名管道中读取数据，并在数据可用时将其打印到stdout。
例如：如果我打开两个终端并在其中一个终端中./execute pipe1 pipe2（pipe1和pipe2是有效的命名管道），然后键入echo "Data here." > pipe1，那么管道的名称（这里是pipe1）、大小和数据应该打印到stdout--这里看起来像pipe1 [25]: Data here.
我知道我需要打开带有O_RDONLY和O_NONBLOCK标志的管道。我看过很多使用select()的人的例子（在这个论坛上有很多），我仍然不明白传递给select()的不同参数在做什么。如果有人能在这里提供指导，那将非常有帮助下面是我目前掌握的代码。

 int pipeRouter(char[] fifo1, char[] fifo2){
    fileDescriptor1 = open(fifo1, O_RDONLY, O_NONBLOCK);
    fileDescriptor2 = open(fifo2, O_RDONLY, O_NONBLOCK);

    if(fileDescriptor1 < 0){
        printf("%s does not exist", fifo1);
    }
    if(fileDescriptor2 < 0){
        printf("%s does not exist", fifo2);
    }
}

最佳答案

select允许您等待i/o事件，而不是在read上缩短CPU周期。
因此，在您的示例中，主循环可以如下所示：

for (;;)
{
  int res;
  char buf[256];

  res = read(fileDescriptor1, buf, sizeof(buf));
  if (res > 0)
  {
      printf("Read %d bytes from channel1\n", res);
  }
  res = read(fileDescriptor2, buf, sizeof(buf));
  if (res > 0)
  {
      printf("Read %d bytes from channel2\n", res);
  }
}

如果添加并运行代码，您会注意到：
这个程序实际上做了你想做的——它从两个管道中读取。
一个内核的CPU利用率为100%，即即使没有数据可供读取，程序也会浪费CPU。
为了解决这个问题，引入了select和pollapi对于select我们需要知道描述符（我们所做的），以及它们的最大值。
所以让我们稍微修改一下代码：

 for (;;)
 {
    fd_set fds;
    int maxfd;

    FD_ZERO(&fds); // Clear FD set for select
    FD_SET(fileDescriptor1, &fds);
    FD_SET(fileDescriptor2, &fds);

    maxfd = fileDescriptor1 > fileDescriptor2 ? fileDescriptor1 : fileDescriptor2;

    select(maxfd + 1, &fds, NULL, NULL, NULL);
    // The minimum information for select: we are asking only about
    // read operations, ignoring write and error ones; and not
    // defining any time restrictions on wait.


   // do reads as in previous example here
 }

在运行改进的代码时，CPU不会浪费太多，但是您会注意到，即使没有特定管道的数据，但有另一个管道的数据，也会执行read操作。
要检查哪个管道实际拥有数据，请在调用后使用FD_ISSET：

if (FD_ISSET(fileDescriptor1, &fds))
{
   // We can read from fileDescriptor1
}
if (FD_ISSET(fileDescriptor2, &fds))
{
   // We can read from fileDescriptor2
}

因此，在加入上述内容后，代码将如下所示：

for (;;)
{
  fd_set fds;
  int maxfd;
  int res;
  char buf[256];

  FD_ZERO(&fds); // Clear FD set for select
  FD_SET(fileDescriptor1, &fds);
  FD_SET(fileDescriptor2, &fds);

  maxfd = fileDescriptor1 > fileDescriptor2 ? fileDescriptor1 : fileDescriptor2;

  select(maxfd + 1, &fds, NULL, NULL, NULL);


  if (FD_ISSET(fileDescriptor1, &fds))
  {
     // We can read from fileDescriptor1
     res = read(fileDescriptor1, buf, sizeof(buf));
     if (res > 0)
     {
        printf("Read %d bytes from channel1\n", res);
     }
  }
  if (FD_ISSET(fileDescriptor2, &fds))
  {
     // We can read from fileDescriptor2
    res = read(fileDescriptor2, buf, sizeof(buf));
    if (res > 0)
    {
        printf("Read %d bytes from channel2\n", res);
    }
  }
}

所以，添加错误处理，就可以设置了。

关于c - C使用select()从两个命名管道(FIFO)中读取，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/28519119/