Boost Asio如何正确封装strand以实现对象安全析构

核心思路 #

要确保析构时strand上所有任务完成且不再提交新任务，必须做到两点：阻止新任务提交到strand，以及等待strand上所有已提交的任务执行完毕。Asio本身没有“内置一键清理”功能，是因为异步模型的灵活性——不同场景下的生命周期管理逻辑差异极大，无法提供通用的标准化方案，需要开发者结合自身逻辑控制对象生命周期。

具体实现步骤 #

1. 用原子标志拦截新任务提交 #

在my_object类中添加一个std::atomic<bool>类型的状态标志（比如is_shutting_down_），所有需要提交到strand的异步操作，在提交前先检查该标志。如果已处于关闭状态，直接拒绝新任务。

示例代码片段：

class my_object {
private:
    std::atomic<bool> is_shutting_down_{false};
    std::optional<asio::strand<asio::io_context::executor_type>> strand_;
    asio::ip::tcp::socket socket_;
    std::array<char, 1024> buffer_;

public:
    // 封装strand任务提交逻辑
    template<typename Func>
    void post_to_strand(Func&& func) {
        if (is_shutting_down_.load(std::memory_order_acquire)) {
            return;
        }
        asio::post(*strand_, std::forward<Func>(func));
    }

    // 异步读取操作的封装示例
    void async_read_some() {
        if (is_shutting_down_.load(std::memory_order_acquire)) {
            return;
        }
        socket_.async_read_some(
            asio::buffer(buffer_),
            asio::bind_executor(*strand_,
                [this](asio::error_code ec, std::size_t bytes_read) {
                    if (!ec && !is_shutting_down_.load(std::memory_order_acquire)) {
                        // 处理读取结果，若未关闭则触发下一次读取
                        async_read_some();
                    }
                }
            )
        );
    }
};

2. 等待strand所有任务执行完毕 #

析构时先设置关闭标志，然后向strand提交一个“空收尾任务”，并等待该任务执行完成。由于strand是串行执行的，这个收尾任务会排在所有已提交任务的最后，它执行完毕就意味着之前的所有strand任务都已处理完成。

示例析构函数实现：

my_object::~my_object() {
    // 标记进入关闭状态，拦截新任务
    is_shutting_down_.store(true, std::memory_order_release);

    // 提前关闭socket，终止正在进行的异步IO操作
    if (socket_.is_open()) {
        asio::error_code ec;
        socket_.close(ec); // 忽略错误，析构阶段无需处理
    }

    if (!strand_) {
        return;
    }

    std::promise<void> completion_promise;
    auto completion_future = completion_promise.get_future();

    // 提交收尾任务到strand，执行时触发promise完成
    asio::post(*strand_, [&completion_promise]() {
        completion_promise.set_value();
    });

    // 等待收尾任务执行，确保所有strand任务已完成
    completion_future.get();

    // 此时可安全销毁strand
    strand_.reset();
}

为什么之前的方案会崩溃？ #

你之前的实现可能存在两个关键问题：

• 未拦截新任务提交：异步操作的回调中可能会触发下一轮异步调用，导致新任务不断被提交到strand，无法完成清理。
• 等待的任务不是strand的最后一个：如果等待的清理任务没有排在所有已提交任务之后，就会出现strand销毁后仍有未执行任务访问已释放对象的情况。

内容的提问来源于stack exchange，提问作者Jean-Michaël Celerier