检查 iofstream 上是否有数据的非阻塞方式

如何解决检查 iofstream 上是否有数据的非阻塞方式

我需要一种方法来以非阻塞方式检查文件 (fifo) 上是否有要读取的数据。 我试过使用 peek;但它被阻塞了，我尝试先 get 然后 unget 一个字符，以便在不更改内容的情况下检查文件；但是 get 再次阻塞了...

我发现的唯一非阻塞解决方案是使用 std::getline(file,line_str) 并检查字符串是否为空；但是这不适合我的需要，因为它改变了文件中的数据。 （数据是一个序列化的对象，一旦我检测到有东西要读取，我就会读取）。

注意：我需要非阻塞：我有多个文件流，需要定期检查所有文件流以查看是否有要读取/反序列化的对象。

这是我想要实现的一个简单示例：

Sender.cpp：

#include <fstream>
#include <iostream>
#include <string>
extern "C"{
    #include <sys/stat.h>      // S_IRUSR,S_IWUSR,mkfifo
}
#include <cerrno>              // errno

int main(int,char** argv) {
    std::string pipe = "foobar";
    if(mkfifo(pipe.c_str(),S_IRUSR | S_IWUSR) < 0){
        if (errno != EEXIST){
            std::cerr << errno;
        }
    }
    std::ofstream file{pipe.c_str()};
    file.write("boop",4); // Simulated object serialization

}

Reader.cpp：

#include <fstream>
#include <iostream>
#include <string>
extern "C"{
    #include <sys/stat.h>      // S_IRUSR,S_IRUSR | S_IWUSR) < 0){
        if (errno != EEXIST){
            std::cerr << errno;
        }
    }
    std::ifstream file{pipe.c_str()};
    // ...
    /* Do check for data and read/deserialize if any data */
    // This is in some sort of loop that goes over the different
    // filestreams and checks to see if they have data to treat
}

非常感谢任何帮助...

编辑： 按照 Zoso 的回答，我尝试使用文件大小来确定文件是否已更改；然而，尝试获取 fifo 命名管道的大小是不可能的： filesystem error: cannot get file size: Operation not supported [myFilePath]

解决方法

我不确定这是否适用于您的特定用例，但您可以使用 filesystem API。一个简单的例子是

#include <iostream>
#include <fstream>
#include <filesystem>

namespace fs = std::filesystem;
int main()
{
    while (true) {
        auto path = fs::current_path().append("test");
        std::cout <<"Press enter to know file size of "<<path.c_str() <<'\n';
        char c= getchar();
        try {
            std::cout<<"Size of "<<path.c_str()<<"is "<<fs::file_size(path)<<'\n';
        } catch(fs::filesystem_error& e) {
            std::cout << e.what() << '\n';
        }        
    }
}

当文件获取数据时，可以根据增加的 size 进行跟踪，并且可以在使用该数据时跟踪要处理的数据。