使用boost::process::async_pipe实现进程间通信时read阻塞问题排查

核心问题分析 #

你的代码卡在io_context::run()的读操作，主要有两个原因：

1. 命名管道的客户端-服务器模型未正确实现
   Windows命名管道要求必须有一端作为服务器端创建并监听管道连接，另一端作为客户端连接已创建的管道。你在同一个进程里直接用同一个管道名创建两个async_pipe，没有区分服务端和客户端，导致管道连接未真正建立，读操作一直等待有效连接的数据。

2. IO上下文的执行顺序错误
   你先启动并join了io的线程，io.run()在async_write完成后就会退出，之后才启动io2.run()的线程。此时读操作才开始，但写操作已完成，且管道连接未建立，自然读不到数据，一直阻塞。

另外明确：boost::process的async_pipe确实可以用来实现命名管道进程间通信，它不仅能用于子进程的标准IO重定向，也能作为独立的命名管道使用，只是需要遵循命名管道的客户端-服务器模型。

修正后的代码示例 #

通过命令行参数区分服务器和客户端，分别运行两个进程实现通信：

服务器端代码（接收数据）

#include <thread>
#include <iostream>
#include "boost/asio.hpp"
#include "boost/process.hpp"

namespace asio = boost::asio;
namespace bp = boost::process;

std::string create_named_pipe_name(const std::string& name)
{
    return R"(\\.\pipe\)" + name;
}

int main()
{
    asio::io_context io;
    // 创建命名管道服务器，等待客户端连接
    bp::async_pipe server_pipe(io, create_named_pipe_name("test_pipe"), bp::pipe_mode::server);

    std::vector<char> buffer(3, '*');
    asio::async_read(server_pipe, asio::buffer(buffer),
        [&buffer](const boost::system::error_code& ec, std::size_t size)
        {
            if (!ec) {
                std::cout << "服务器收到消息: " << std::string(buffer.data(), size) << std::endl;
            } else {
                std::cerr << "服务器读失败: " << ec.message() << std::endl;
            }
        });

    io.run();
    return 0;
}

客户端代码（发送数据）

#include <thread>
#include <iostream>
#include "boost/asio.hpp"
#include "boost/process.hpp"

namespace asio = boost::asio;
namespace bp = boost::process;

std::string create_named_pipe_name(const std::string& name)
{
    return R"(\\.\pipe\)" + name;
}

int main()
{
    asio::io_context io;
    // 连接到已创建的命名管道服务器
    bp::async_pipe client_pipe(io, create_named_pipe_name("test_pipe"), bp::pipe_mode::client);

    std::string message = "CCC";
    asio::async_write(client_pipe, asio::buffer(message),
        [&message](const boost::system::error_code& ec, std::size_t size)
        {
            if (!ec) {
                std::cout << "客户端发送消息: " << message << std::endl;
            } else {
                std::cerr << "客户端写失败: " << ec.message() << std::endl;
            }
        });

    io.run();
    return 0;
}

运行说明 #

1. 先启动服务器程序，它会创建管道并等待客户端连接
2. 再启动客户端程序，客户端会连接管道并发送数据
3. 服务器收到数据后输出，双方的io_context会在操作完成后正常退出

额外提示 #

如果一定要在同一个进程内测试（非标准进程间通信场景），需要用线程分别启动服务器和客户端逻辑，确保服务器先创建管道再让客户端连接，同时两个io_context的run()要并行运行，不能先join一个再启动另一个。

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