asio .async_ *将不会运行，除非主线程调用io_service.run

Question

我最近一直在使用boost asio和一些新的C++ 11结构。以下是导致意外行为的代码示例部分（至少对我而言）。

void Server::startAccept() 
{ 
    connections_.push_back(std::make_shared<Connection>(io_service_)); 
    acceptor_.async_accept(connections_.back()->socket(), std::bind(&Server::accept_handler, this, connections_.back(), std::placeholders::_1)); 
} 

void Server::accept_handler(std::shared_ptr<Connection> con, const boost::system::error_code& ec) 
{ 
    startAccept(); 

    if (!ec) { 
     con->start(); 
    } 
} 

我拨打电话到服务器:: startAccept之前，我创建io_service对象::工作的一个实例，）的std ::线程池，要求io_service_.run（。在我调用startAccept之后，主线程只是等待命令行输入。

我希望我的线程池中的一个线程在连接启动时运行Server :: accept_handler。这不会发生。相反，我必须从主线程调用io_service_.run（）。

现在我玩了一段时间，我发现我可以通过这样达到预期的行为：

void Server::startAccept() 
{ 
    connections_.push_back(std::make_shared<Connection>(io_service_)); 
    io_service_.post([this]() { acceptor_.async_accept(connections_.back()->socket(), std::bind(&Server::accept_handler, this, connections_.back(), std::placeholders::_1)); }); 
} 

void Server::accept_handler(std::shared_ptr<Connection> con, const boost::system::error_code& ec) 
{ 
    startAccept(); 

    if (!ec) { 
     con->start(); 
    } 
} 

是什么.async_之间的差异*操作和io_service.post？

编辑：定义BOOST_ASIO_ENABLE_HANDLER_TRACKING

当我编译并运行了一个程序，然后连接到服务器的代码，我包括第一块是这样的输出：

@asio|1350656555.431359|0*1|socket@00A2F710.async_accept 

当我运行第二块代码我包括并连接到服务器我得到这个输出：

@asio|1350656734.789896|0*1|io_service@00ECEC78.post 
@asio|1350656734.789896|>1| 
@asio|1350656734.789896|1*2|socket@00D0FDE0.async_accept 
@asio|1350656734.789896|<1| 
@asio|1350656756.150051|>2|ec=system:0 
@asio|1350656756.150051|2*3|io_service@00ECEC78.post 
@asio|1350656756.150051|>3| 
@asio|1350656756.150051|2*4|socket@00EE9090.async_send 
@asio|1350656756.150051|3*5|socket@00D0FDE0.async_accept 
@asio|1350656756.150051|2*6|socket@00EE9090.async_receive 
@asio|1350656756.150051|<3| 
@asio|1350656756.150051|>4|ec=system:0,bytes_transferred=54 
@asio|1350656756.150051|<2| 
@asio|1350656756.150051|<4| 
@asio|1350656758.790803|>6|ec=system:10054,bytes_transferred=0 
@asio|1350656758.790803|<6| 

编辑2：创建线程的洞察力

for (int i = 0; i < NUM_WORKERS; i++) { 
    thread_pool.push_back(std::shared_ptr<std::thread>(new std::thread([this]() { io_service_.run(); }))); 
} 

Answer 1

如果您不忘记为池中的每个线程调用io_service :: run，并且您使用io_service :: work来避免从io_service :: run循环退出，那么您在第一种情况下的代码是绝对正确的。

这里是工作示例（我忽略了连接处理和程序的正确关机）

class Connection 
{ 
public: 
    Connection(boost::asio::io_service & io_serivce) : socket_(io_serivce) {} 
    boost::asio::ip::tcp::socket & socket() { return socket_; } 
private: 
    boost::asio::ip::tcp::socket socket_; 
}; 

class Server 
{ 
public: 
    Server(boost::asio::io_service & io_serivce, const std::string & addr, const std::string & port) : io_service_(io_serivce), acceptor_(io_service_) { 
     boost::asio::ip::tcp::resolver resolver(io_service_); 
     boost::asio::ip::tcp::resolver::query query(addr, port); 
     boost::asio::ip::tcp::endpoint endpoint = *resolver.resolve(query); 
     acceptor_.open(endpoint.protocol()); 
     acceptor_.set_option(boost::asio::ip::tcp::acceptor::reuse_address(true)); 
     acceptor_.bind(endpoint); 
     acceptor_.listen(); 
     startAccept(); 
    } 

    void startAccept(){ 
     connections_.push_back(boost::make_shared<Connection>( boost::ref(io_service_)));  
     acceptor_.async_accept(connections_.back()->socket(), boost::bind(&Server::accept_handler, this, connections_.back(), _1)); 
    } 

    void Server::accept_handler(boost::shared_ptr<Connection> con, const boost::system::error_code& ec) 
    { 
     std::cout << "start connection" << std::endl; 
     startAccept(); 
    } 

private: 
    boost::asio::io_service & io_service_; 
    boost::asio::ip::tcp::acceptor acceptor_; 
    std::vector< boost::shared_ptr<Connection> > connections_; 
}; 

int main(int argc, char * argv[]) 
{ 
    // thread pool 
    boost::thread_group threads_; 
    boost::asio::io_service io_service_; 
    boost::asio::io_service::work work_(io_service_); 

    const size_t kThreadsCount = 3; 
    for (std::size_t i = 0; i < kThreadsCount; ++i) { 
     threads_.create_thread(boost::bind(&boost::asio::io_service::run, &io_service_)); 
    } 

    Server s(io_service_, "127.0.0.1", "8089"); 

    char ch; 
    std::cin >> ch; 
    return 0; 
} 

Answer 2

的io_service.run功能是实际的事件循环，什么它基本上是调用io_service.post在一个循环。

编辑：从io_service.post文档：

要求io_service对象调用指定的处理程序，并立即返回。

而且

的io_service保证了处理器将只在其中run()，run_one()，poll() or poll_one()成员函数正在调用的线程调用。

你应该能做的就是实现什么自己的事件循环，调用io_service.run_one，或致电io_service.run让加速处理事件循环。 其中线程用于运行事件循环，所有事件处理程序将从您运行事件循环的线程中调用。