std::getline关闭流后仍阻塞，求可靠解除阻塞方法

问题根源 #

std::ifstream的close()操作无法中断已处于等待状态的std::getline调用——当线程阻塞在FIFO读取时，底层系统调用（如read()）不会因为文件描述符被关闭而立即返回，除非FIFO的所有写端都被关闭。你的示例代码中仅关闭了读端，写端txStream仍保持打开，因此读端的阻塞状态无法解除。

可靠的解决方法 #

方法1：关闭所有FIFO写端触发读端返回

当FIFO的所有写端关闭时，读端的底层read()调用会返回0，触发EOF状态，std::getline会失败并返回，线程得以正常退出。修改你的代码逻辑：

std::this_thread::sleep_for(250ms);
// 先关闭写端，触发读端EOF
txStream.close();
// 再关闭读端
rxStream.close();

此操作后，读端的std::getline会检测到EOF并返回，线程结束，rr.get()不会再阻塞。

方法2：带超时的读取逻辑替代阻塞getline

如果需要在不关闭写端的情况下中断读取，可以结合底层文件描述符与select()/poll()实现超时检测，配合原子标志控制退出：

// 全局或类内定义原子退出标志
std::atomic<bool> shouldExit(false);

// 修改接收线程逻辑
std::future<void> rr = std::async([&]() {
  std::string line;
  int fd = rxStream.native_handle();
  
  while (!shouldExit.load()) {
    fd_set readfds;
    struct timeval tv;
    FD_ZERO(&readfds);
    FD_SET(fd, &readfds);
    
    // 设置100ms超时，用于定期检查退出标志
    tv.tv_sec = 0;
    tv.tv_usec = 100000;
    
    int ret = select(fd + 1, &readfds, nullptr, nullptr, &tv);
    if (ret == -1) {
      // 出错或被信号中断，直接退出
      break;
    } else if (ret == 0) {
      // 超时，继续循环检查退出标志
      continue;
    } else {
      // 有数据可读，尝试读取一行
      if (!std::getline(rxStream, line)) {
        // 检测到EOF或读取失败，退出
        break;
      }
      std::cout << " Line is: " << line << std::endl;
    }
  }
});

// 在需要退出时设置标志
std::this_thread::sleep_for(250ms);
shouldExit.store(true);
rxStream.close();

方法3：C++20线程中断机制（推荐）

C++20引入的std::jthread支持原生线程中断，可通过stop_token主动通知线程退出：

// 使用std::jthread替代std::async+std::future
std::jthread rr([&](std::stop_token stoken) {
  std::string line = "XX";
  int fd = rxStream.native_handle();
  
  while (!stoken.stop_requested()) {
    fd_set readfds;
    struct timeval tv;
    FD_ZERO(&readfds);
    FD_SET(fd, &readfds);
    
    // 短超时用于检查中断请求
    tv.tv_sec = 0;
    tv.tv_usec = 100000;
    
    int ret = select(fd + 1, &readfds, nullptr, nullptr, &tv);
    if (ret > 0) {
      if (!std::getline(rxStream, line)) break;
      std::cout << " Line is: " << line << std::endl;
    }
  }
});

// 请求线程中断并等待退出
std::this_thread::sleep_for(250ms);
rr.request_stop();
rr.join();

示例代码修改后的完整版本 #

最直接的修复是确保关闭所有写端，触发读端EOF：

void test() {
  std::filesystem::path path1("/tmp/f1");
  int retval = mkfifo(path1.string().c_str(), (unsigned int)0660);

  // Open TX side
  std::ofstream txStream;

  std::future<void> tt = std::async([&]() {
    txStream.open(path1, std::ios::binary | std::ios::out | std::ios::trunc);
    return;
  });

  // Open RX side
  std::ifstream rxStream;
  rxStream.open(path1, std::ios::binary | std::ios::in);

  // Setup getline
  std::future<void> rr = std::async([&]() {
    std::string line = "XX";
    std::getline(rxStream, line);
    std::cout << " Line is: " << line << std::endl;
  });

  std::this_thread::sleep_for(250ms);
  
  // 先关闭写端，触发读端EOF
  if (txStream.is_open()) {
    txStream.close();
  }
  // 再关闭读端
  rxStream.close();

  if (tt.valid()) {
    tt.get();
    std::cout << "Done Tx" << std::endl;
  } else {
    std::cout << "Tx task not valid" << std::endl;
  }

  if (rr.valid()) {
    rr.get();
    std::cout << "Done Rx" << std::endl;
  } else {
    std::cout << "Rx task not valid" << std::endl;
  }
}

内容的提问来源于stack exchange，提问作者Claude