21

有一个使用 boost::asio 的例子。

  1. 为什么这个例子使用 boost::asio::io_service::work ?
  2. 为什么srv.run ();不调用线程中的任务执行?
int main()
{
    boost::asio::io_service srv;
    boost::asio::io_service::work work(srv);
    boost::thread_group thr_grp;
    thr_grp.create_thread(boost::bind(&boost::asio::io_service::run, &srv));
    thr_grp.create_thread(boost::bind(&boost::asio::io_service::run, &srv));

    srv.post(boost::bind(f1, 123));
    srv.post(boost::bind(f1, 321));
    //sync

    srv.post(boost::bind(f2, 456));
    srv.post(boost::bind(f2, 654));
    //sync

    srv.stop();
    thr_grp.join();
}

更新: 在没有 io_service::work 的情况下使用 io_service 时,poll 和 run 有什么区别?

int main()
{
    boost::asio::io_service srv;
    //boost::asio::io_service::work work(srv);
    std::vector<boost::thread> thr_grp;

    srv.post(boost::bind(f1, 123));
    srv.post(boost::bind(f1, 321));
    //sync

    srv.post(boost::bind(f2, 456));
    srv.post(boost::bind(f2, 654));
    //sync

    // What is the difference between the poll and run, when io_service without work?
    thr_grp.emplace_back(boost::bind(&boost::asio::io_service::poll, &srv));// poll or run?
    thr_grp.emplace_back(boost::bind(&boost::asio::io_service::run, &srv));// poll or run? 

    srv.stop();
    for(auto &i : thr_grp) i.join();

    int b;
    std::cin >> b;

    return 0;
}
4

1 回答 1

23

当在io_service::run没有工作对象的情况下调用该方法时,它将立即返回。通常,这不是大多数开发人员正在寻找的行为。当然也有一些例外,但大多数开发人员都希望指定一个线程来处理所有异步处理,并且在被告知之前不希望该线程退出。这就是您的代码示例所做的。

io_service::run方法在 create_thread 方法中被指定为委托或函数指针。因此,当从create_thread方法创建线程时,它将调用该io_service::run方法并将io_service对象作为参数传递。通常一个io_service对象可以与多个套接字对象一起使用。

当关闭应用程序或不再需要所有客户端/服务器之间的通信并且预计不需要启动任何新连接时,通常会调用 stop 方法。

于 2013-06-17T21:41:48.850 回答