boost::weak_from_raw相关的测试程序

### Boost UDP Server 中 `tr1::bad_weak_ptr` 异常的处理 在使用 Boost.Asio 开发 UDP 服务器时，若通过 `shared_from_this()` 启动异步操作，可能会遇到如下异常信息： ``` terminate called after throwing an instance of 'std::bad_weak_ptr' what(): bad_weak_ptr Aborted ``` 该异常通常表明在对象尚未绑定到 `shared_ptr` 之前调用了 `shared_from_this()`，导致无法正确获取共享指针。Boost.Asio 的异步模型依赖于对象生命周期管理机制，因此必须确保异步操作期间对象不会被提前销毁[^2]。 #### 原因分析与解决方法 ##### 1. 对象未通过 `shared_ptr` 管理即调用 `shared_from_this()` `shared_from_this()` 只能在已经被 `shared_ptr` 所管理的对象中安全调用。如果直接使用原始指针构造对象并调用该方法，将抛出 `bad_weak_ptr` 异常。例如： ```cpp udp_server server(io); // 错误：未使用 shared_ptr server.do_send(); ``` 正确的做法是通过静态工厂函数创建对象，并返回 `shared_ptr` 实例[^3]： ```cpp class udp_server : public boost::enable_shared_from_this<udp_server> { public: static boost::shared_ptr<udp_server> create(boost::asio::io_context& io) { return boost::shared_ptr<udp_server>(new udp_server(io)); } }; ``` ##### 2. 在构造函数中启动异步操作时调用 `shared_from_this()` 若在构造函数内部立即调用 `async_*` 方法并传入 `shared_from_this()`，此时对象尚未完全构造完毕，也可能引发 `bad_weak_ptr` 异常。应避免在构造函数中直接启动异步操作，而应在构造完成后再触发相关逻辑。 示例错误代码： ```cpp udp_server(boost::asio::io_context& io) : socket_(io, udp::endpoint(udp::v4(), 12345)) { do_receive(shared_from_this()); // 错误：构造函数中调用 shared_from_this() } ``` 正确方式应为构造完成后手动调用启动函数： ```cpp udp_server(boost::asio::io_context& io) : socket_(io, udp::endpoint(udp::v4(), 12345)) {} void start() { do_receive(); } ``` ##### 3. 多线程环境下未正确管理对象生命周期 当多个线程并发执行异步操作时，若未确保对象始终由 `shared_ptr` 管理，可能导致对象提前释放。建议在所有异步操作回调中捕获 `shared_from_this()`，以延长对象生命周期直至异步操作完成[^1]。 例如，在 `do_send()` 函数中保持对 `shared_from_this()` 的引用： ```cpp void do_send() { auto self(shared_from_this()); const std::string& message = send_queue_.front().first; const udp::endpoint& endpoint = send_queue_.front().second; socket_.async_send_to(boost::asio::buffer(message), endpoint, [this, self](const boost::system::error_code& ec, std::size_t /*bytes_sent*/) { std::lock_guard<std::mutex> lock(queue_mutex_); send_queue_.pop_front(); if (!send_queue_.empty()) { do_send(); } }); } ``` #### 示例修复后的完整构造函数和启动流程 ```cpp explicit udp_server(boost::asio::io_context& io) : socket_(io, udp::endpoint(udp::v4(), 12345)) {} void start() { do_receive(); } void do_receive() { socket_.async_receive_from( boost::asio::buffer(recv_buffer_), remote_endpoint_, boost::bind(&udp_server::handle_receive, shared_from_this(), _1, _2)); } ``` ---