2

我boost::process用来异步读取 Windows 中控制台应用程序的输出。我注意到每次大约 4k 数据后触发读取事件。

如果我将缓冲区“buf”设置为一个较小的值，则不会发生任何变化：仅在传输 4k 数据后才会多次触发事件。

据我了解，这可能是 Windows 中使用的一种安全机制，可以避免从管道读取时出现死锁。

有什么办法boost::process可以改变 PIPE 用来传输数据的缓冲区的大小？

   #include <boost/process.hpp>
   #include <boost/asio.hpp>

   using namespace boost::process;
   boost::asio::io_service ios;

   std::vector<char> buf(200);
   async_pipe ap(ios);

   void read_from_buffer(const boost::system::error_code &ec, std::size_t size)
   {
    if (ec)
    {
        std::cout << "error" << std::endl;
        return;
    }

    std::cout << "--read-- " << size << std::endl;
    for (size_t i = 0; i < size; i++) std::cout << buf[i];
    std::cout << std::endl;


   ap.async_read_some(boost::asio::buffer(buf), read_from_buffer);
   }


   int main()
   {    
    child c("MyApp.exe --args", std_out > ap);  
    ap.async_read_some(boost::asio::buffer(buf), read_from_buffer);
    ios.run();
    int result = c.exit_code(); 
   }
4

1 回答 1

1

您可能必须控制“发送”端（所以，MyApp.exe）。

在 UNIX 上有stdbuf（使用setvbuff）unbuffer和类似的。工具可能有一些内置的支持（例如grep --line-buffered）。

在 Windows 上，我不确定。这里有一些提示：禁用重定向标准输出管道上的缓冲（Win32 API，C++）

于 2018-08-02T16:24:05.543 回答