提升客户端卡住

Question

http://www.boost.org/doc/libs/1_46_0/doc/html/boost_asio/example/chat/chat_client.cpp

我正在基于他上面的示例在客户端应用程序上工作。

我想在separte线程中进行客户端连接，以便UI不会卡住。这里的用户界面正在停滞不前。
1.你能告诉我如何实现这个目标吗？
2.这条线的含义是什么？ boost :: thread t（boost :: bind（& boost :: asio :: io_service :: run，& io_service））;
t.join（）;
此行是否创建单独的连接线程？

client::client(boost::asio::io_service& io_service, tcp::resolver::iterator endpoint_iterator) 
    : io_service_(io_service), 
    resolver_(io_service), 
    socket_(io_service_) 
{ 
    tcp::endpoint endpoint = *endpoint_iterator; 
    socket_.async_connect( endpoint, 
           boost::bind(&client::handle_connect, this,boost::asio::placeholders::error, 
          ++endpoint_iterator)); 

} 
void client::handle_connect(const boost::system::error_code& error, 
    tcp::resolver::iterator endpoint_iterator) 
{ 
    strcpy(data_,"Hello"); 
if (!error) 
{ 
    /*boost::asio::async_read(socket_, 
           boost::asio::buffer(data_, MAX_PATH), 
           boost::bind(&client::handle_read, this, 
           boost::asio::placeholders::error));*/ 
     boost::asio::async_write(socket_, boost::asio::buffer(data_, MAX_PATH), 
           boost::bind(&client::handle_read, this, 
          boost::asio::placeholders::error)); 
} 
else if (endpoint_iterator != tcp::resolver::iterator()) 
{ 
    socket_.close(); 
    tcp::endpoint endpoint = *endpoint_iterator; 
    socket_.async_connect( endpoint, 
          boost::bind(&client::handle_connect, this, 
          boost::asio::placeholders::error, ++endpoint_iterator)); 
} 
} 

void client::handle_read(const boost::system::error_code& error) 
{ 
if (!error) 
{ 
    memset(data_,0,MAX_PATH); 
    boost::asio::async_read( socket_, 
           boost::asio::buffer(data_, MAX_PATH), 
           boost::bind(&client::handle_read, this, 
           boost::asio::placeholders::error)); 

    if (strcmp(data_,"Hello Response")==0) 
    { 
     MessageBox(NULL,_T("Regd Done"),_T("Vue"),1); 
     // return ; 
    } 


} 

} 

CConnectionMgr::CConnectionMgr(void) 
{ 

} 
void CConnectionMgr::Connect() 
{ 
try 
{ 
    char* host = "192.168.4.84"; 
    char* port = "55555"; 
    boost::asio::io_service io_service; 

    tcp::resolver resolver(io_service); 
    tcp::resolver::query query(tcp::v4(),host , port); 
    tcp::resolver::iterator iterator = resolver.resolve(query); 

    c = new client(io_service, iterator); 

    //boost::thread thrd(boost::bind(&boost::asio::io_service::run, &io_service)); 
    boost::thread t(boost::bind(&boost::asio::io_service::run, &io_service)); 
    t.join(); 
    // MessageBox(NULL,_T("Join"),_T("ff"),1); 
} 
catch (std::exception& e) 
{ 
    CString csMsg(e.what()); 
    MessageBox(NULL,csMsg,_T("ff"),1);  
} 
} 

Answer 1

1. 你能告诉我该如何实现吗？

你可以启动升压线程在主即你输入之前的某个地方UI事件循环（阻塞调用），但不做加盟。

查看HTTP服务器示例：在其中一个示例中，它显示了如何在主服务器上启动io_service并通过CTRL-c停止它。在你的情况下，你可能会使用GUI按钮或事件来做到这一点。一旦你调用io_service stop方法，你就可以在线程上进行连接。

1. 这条线的含义是什么？ boost :: thread t（boost :: bind（& boost :: asio :: io_service :: run，& io_service））;

• 运行。该io_service ::在一个新的线程中运行

t.join（）;

• 等待线程完成像janm指出，这将发生一次。该io_service耗尽工作或一次。该io_service ::停止方法被调用

Answer 2

“t.join（）”等待线程't'退出。线程't'在io_service上运行run（）方法，并在没有剩余的I/O完成时退出。

因此，您的Connect（）方法将阻塞，直到所有I/O完成，这不是您想要的。如果您要执行异步I/O以便您的客户端不会阻塞，则需要为您的I/O上下文设计一种方式与我们的UI上下文进行通信。它不会发生魔法。