如何在boost::asio中等待std::future且不阻塞io_context？

要实现非阻塞等待外部回调式异步操作，同时不阻塞io_context，你需要将外部操作与Boost.Asio的协程模型结合，避免使用std::future::wait()这类阻塞调用。以下是几种可行的实现方式：

方法一：使用Boost.Asio原生promise（推荐） #

Boost.Asio提供了适配协程的promise类型，配合co_await可以实现异步等待，不会阻塞线程：

#include <boost/asio/promise.hpp>

boost::asio::awaitable<void> NRClient::callAsyncOperation() {
    // 获取当前协程的执行器，保证回调在正确的线程上下文恢复协程
    auto executor = co_await boost::asio::this_coro::executor();
    boost::asio::promise<boost::system::error_code> promise(executor);
    auto future = promise.get_future();

    // 传入回调，完成时设置promise的值
    exampleAsyncOperation([promise = std::move(promise)](boost::system::error_code ec) mutable {
        promise.set_value(ec);
    });

    // 异步等待结果，协程会暂停，io_context可继续处理其他任务
    boost::system::error_code ec = co_await future;
    
    // 在这里处理操作结果
    if (ec) {
        // 处理错误逻辑
    }
}

方法二：手动控制协程挂起与恢复 #

通过直接操作协程上下文，手动在回调中恢复协程，适合需要更精细控制的场景：

boost::asio::awaitable<void> NRClient::callAsyncOperation() {
    auto executor = co_await boost::asio::this_coro::executor();
    boost::system::error_code ec;
    // 获取当前协程的上下文对象
    auto coro = co_await boost::asio::this_coro::coroutine();

    exampleAsyncOperation([&, coro, executor](boost::system::error_code callback_ec) {
        ec = callback_ec;
        // 将协程恢复操作post到executor，保证线程安全
        boost::asio::post(executor, [coro]() mutable {
            coro.resume();
        });
    });

    // 挂起协程，等待回调触发恢复
    co_await boost::asio::suspend_always{};

    // 处理操作结果
    if (ec) {
        // 错误处理
    }
}

方法三：用async_initiate包装外部操作 #

通过Boost.Asio的async_initiate将回调式操作包装为可co_await的异步操作，符合Asio的异步操作范式：

namespace detail {
    template <typename CompletionToken>
    auto async_wrap_example(CompletionToken&& token) {
        return boost::asio::async_initiate<CompletionToken, void(boost::system::error_code)>(
            [](auto&& completion_handler) {
                exampleAsyncOperation(std::forward<decltype(completion_handler)>(completion_handler));
            },
            token
        );
    }
}

boost::asio::awaitable<void> NRClient::callAsyncOperation() {
    boost::system::error_code ec = co_await detail::async_wrap_example(boost::asio::use_awaitable);
    // 处理结果
}

为什么原代码会阻塞io_context？ #

原代码中std::future::wait()是阻塞调用，会占用io_context的工作线程，导致线程无法处理其他异步任务。而上述方法均通过协程挂起机制，让线程在等待期间可以继续处理io_context中的其他任务，实现了真正的非阻塞等待。

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