使用 boost::asio 时的参考问题（我猜）

Question

我正在基于 提升网站。现在，该代码与我的代码之间的区别在于该示例使用服务器构造函数来启动异步操作。这是有道理的，因为服务器应该一直监听。另一方面，在我的客户端中，我想首先构造对象，然后有一个 send() 函数，该函数首先连接到端点，然后发送一个请求，最后侦听回复。这也有道理，不是吗？

当我创建对象（客户端）时，我以与服务器示例（winmain.cpp）相同的方式进行操作。它看起来像这样：

client c("www.boost.org);
c.start(); // starts the io_service in a thread
c.send(msg_);

代码的相关部分如下：

void enabler::send(common::geomessage& msg_)
{
    new_connection_.reset(new connection(io_service_,
        connection_manager_,
        message_manager_, msg_
    ));

    boost::asio::ip::tcp::resolver resolver(io_service_);
    boost::asio::ip::tcp::resolver::query query(host_address, "http");

    resolver.async_resolve(query, boost::bind(
        &enabler::handle_resolve,
        boost::ref(*this),
        boost::asio::placeholders::error,
        boost::asio::placeholders::iterator
    ));
}

void enabler::run()
{
    io_service_.run();
}

问题是程序卡在此处的某个地方。最后打印的是“正在解析主机”，之后程序结束。我不知道为什么，因为 io_service 应该阻塞，直到所有异步操作返回到它们的回调。但是，如果我改变调用函数的顺序，它就会起作用。如果我在调用 async_resolve() 之后立即调用 run()，并且在主程序中省略调用 start()，那么它就可以工作！

在这种情况下，io_service 会按其应有的方式阻塞，并且我可以看到我收到了来自服务器的响应。

这与我从与调用 async_resolve() 相同的类内部调用 run() 的事实有关。这是真的吗？我想当我调用run()时我需要提供主程序的引用，是这样的吗？

我一直在努力让 io_service::work 工作，但程序卡住了，是的，出现了与上述类似的问题。所以它并没有真正的帮助。

那么，我该怎么做才能做到这一点呢？正如我之前所说，我想要的是能够创建客户端对象并让 io_service 始终在客户端类内的单独线程中运行。其次，有一个函数 send()，用于向服务器发送请求。

Answer 1

在调用 run() 之前，您至少需要开始一些工作，因为当没有更多工作要做时它就会返回。

如果您在启动异步解析之前调用它，它将不会执行任何工作，因此会返回。

Answer 2

如果您不希望始终有一些工作，为了让 io_service 保持忙碌，您应该在某个范围内构造一个 io_service::work 对象，该对象可以在没有 io_service:: 的情况下退出。 run() 必须首先返回。如果您在单独的线程中运行 io_service ，我想您不会有任何问题。

很难知道你想用这些代码片段做什么。我想你会想做一些类似的事情：

struct client
{
   io_service io_service_;
   io_service::work* w_;
   pthread_t main_thread_;
   client(): w_(new io_service::work(io_service)) { ... }
   void start() { pthread_create(&main_thread_, 0, main_thread, this); }
   static long main_thread(void* arg) { ((client*)arg)->io_service_.run(); }
   // release the io_service and allow run() to return
   void stop() { delete w_; w_ = 0; pthread_join(main_thread_); }
};