如何使用boost::process准确获取stderr/stdout的同步输出？

要解决Boost.Process捕获子进程输出时顺序错乱的问题，核心是模拟cmd.exe的行为：独立监听两个流，按实际接收顺序合并输出，同时保留流的区分标记。以下是实现思路和代码：

问题根源 #

你的原代码采用强制交替读取stdout/stderr的逻辑，这和子进程批量输出的模式冲突——子进程会连续写入某一个流的多行内容，强制交替会导致读取线程在无数据的流上阻塞，错过先到达的另一个流的数据，最终打乱顺序。

正确实现方案 #

用两个独立线程分别读取stdout和stderr，为每个读取到的行分配唯一的顺序号（避免时间戳精度问题），最后按顺序号排序，保证输出顺序与cmd.exe一致，同时能区分流来源。

完整代码 #

#include <boost/process.hpp>
#include <thread>
#include <string>
#include <vector>
#include <mutex>
#include <atomic>
#include <algorithm>
#include <cstdio>

struct OutputLine
{
    std::string data;       // 去掉末尾换行符的输出内容
    bool isStderr;          // 标记是否来自stderr
    uint64_t sequence;      // 接收顺序标记，保证排序准确
};

static std::atomic<uint64_t> g_seq_counter = 0;

static int getCmdOutput(const char* cmd, std::vector<OutputLine>& out)
{
    namespace bp = boost::process;

    out.clear();

    bp::ipstream s_out, s_err;
    std::error_code ec;

    // 创建子进程并重定向输出流
    bp::child c(cmd, bp::std_err > s_err, bp::std_out > s_out, ec);
    if (ec)
        return -1;

    std::mutex mx;

    // 通用读取函数：处理单个流，写入线程安全的结果容器
    auto read_stream = [&](bp::ipstream& stream, bool is_stderr) {
        std::string line;
        while (std::getline(stream, line)) {
            // 移除末尾的\r\n换行符
            while (!line.empty() && (line.back() == '\r' || line.back() == '\n'))
                line.pop_back();
            
            std::scoped_lock lock(mx);
            out.emplace_back(OutputLine{
                std::move(line),
                is_stderr,
                g_seq_counter++
            });
        }
    };

    // 启动两个独立线程分别读取stdout和stderr
    std::thread th_stdout(read_stream, std::ref(s_out), false);
    std::thread th_stderr(read_stream, std::ref(s_err), true);

    // 等待子进程结束和读取线程退出
    c.wait();
    th_stdout.join();
    th_stderr.join();

    // 按接收顺序排序，保证输出顺序与cmd.exe一致
    std::sort(out.begin(), out.end(), [](const OutputLine& a, const OutputLine& b) {
        return a.sequence < b.sequence;
    });

    return c.exit_code();
}

int main(int argc, const char* argv[])
{
    std::vector<OutputLine> out;
    int ret = getCmdOutput("test-exe.exe", out);

    // 输出结果，如需区分流可添加标记
    for (const auto& line : out) {
        // printf("[%s] %s\n", line.isStderr ? "stderr" : "stdout", line.data.c_str());
        printf("%s\n", line.data.c_str());
    }

    printf("test-exe.exe return: %d\n", ret);
    return 0;
}

关键说明 #

1. 独立线程读取：两个线程分别处理stdout和stderr，避免强制交替导致的阻塞问题，让每个流的读取独立进行。
2. 顺序号标记：用原子递增的sequence变量为每个行分配唯一顺序号，排序后严格保证接收顺序，比时间戳更可靠。
3. 线程安全容器：用std::mutex保护结果容器，避免多线程写入时的数据竞争。

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