1

每当发生这种情况时，我正在使用boost::process::child并boost::process::async_pipe启动一个应用程序并异步（通过boost::asio）读取应用程序在屏幕上输出的所有内容。

我还想通过使用child::running()方法检查应用程序是否还活着；如果没有运行，我想使用child::exit_code.

这非常有用，特别是因为它是一种通知应用程序崩溃或意外退出的方法（我找不到更好的方法）；当应用程序退出时，使用boost::system::error_codeset 调用回调。

你知道我是否可以在调用的回调中使用这两种方法async_pipe::async_read_some吗？

一般来说，更简单的问题是线程是否安全（在 Windows 和 Linux 中）child::running()。child::exit_code()

 namespace bp = boost::process;

 char my_buffer[1024];

 boost::asio::io_service io;
 bp::async_pipe in_pipe(io);

 void handle_pipe_read(const boost::system::error_code &ec, std::size_t bytes_transferred);

 void schedule_read()  {
     in_pipe.async_read_some(
         boost::asio::buffer(my_buffer),
         boost::bind(&handle_pipe_read, 
                  boost::asio::placeholders::error,
                  boost::asio::placeholders::bytes_transferred));
 }

 void handle_pipe_read(
    const boost::system::error_code &ec, 
    std::size_t bytes_transferred
    )
 {
     // Q: Is this call possible? 'handle_pipe_read' can run in any thread
     if(c->running())
        std::cout << "I am alive" << std::endl;
     else
        std::cout << "EXIT CODE:" << c->exit_code() << std::endl;

     if(ec) return; //app probably exit

     // Do something with buffer and re-schedule

     schedule_read();
 }

 int main() {
   bp::child c("my_program_url", bp::std_out > in_pipe);
   any_c = &c;

   schedule_read();
   io.run();    
 }
4

2 回答 2

1

由于您只io_service::run()在主线程上运行，所有完成处理程序也在那里运行。没有穿线。

请记住将 io_service 传递给孩子，并使用on_exit处理程序：

Live On Coliru

#include <boost/process.hpp>
//#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <system_error>
#include <utility>
#include <iostream>

namespace bp = boost::process;

char my_buffer[1024];

boost::asio::io_service io;
bp::async_pipe in_pipe(io);

void handle_pipe_read(const boost::system::error_code &ec, std::size_t bytes_transferred);

void schedule_read() {
    in_pipe.async_read_some(
        boost::asio::buffer(my_buffer),
        boost::bind(&handle_pipe_read, _1, _2));
}

void handle_pipe_read(const boost::system::error_code &ec, std::size_t bytes_transferred) {
    if (ec)
        return; // app probably exit

    // Do something with buffer and re-schedule
    std::cout.write(my_buffer, bytes_transferred);

    if (in_pipe.is_open())
        schedule_read();
}

int main() {
    bp::child c("/bin/ls", bp::std_out > in_pipe,
            bp::on_exit([](int code, std::error_code ec) {
                std::cout << "Child exited (" << code << "): " << ec.message() << std::endl;
                in_pipe.close();
            }), io);

    schedule_read();
    io.run();

    std::cout << "Service done (" << c.exit_code() << ")" << std::endl;
}

印刷：

a.out
main.cpp
Child exited (0): Success
Service done (0)
于 2017-12-05T13:01:21.593 回答
0

对我有用的唯一解决方案是以下

  1. 安排完成阅读
  2. 总是检查呼叫child::running()
  3. 在 error_code 集上不要重新安排

当管道损坏（由于崩溃）时，读取的完成处理程序将 boost::error_code 参数设置为 true。尽管如此，当 boost::error_code 未设置时，我也看到 child::running() 为 false 的情况。

于 2017-12-07T18:38:22.723 回答