ブーストクライアントは、私は上記の彼の例に基づいてクライアントアプリケーションに取り組んでいます

Question

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

を立ち往生。

クライアント接続をseparteスレッドで実行して、UIがスタックしないようにしたかったのですが、ここで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サーバーの例を見てください。その1つでは、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一度実行したら、stopメソッドがあなたのreply.Iため

Answer 2

"t.join（）"はスレッド 't'が終了するのを待ちます。スレッド 't'はio_serviceでrun（）メソッドを実行しており、終了するI/Oが残っていないと終了します。

したがって、すべてのI/Oが終了するまでConnect（）メソッドはブロックされます。クライアントがブロックしないように非同期I/Oを行う場合は、I/OコンテキストがUIコンテキストと通信する方法を設計する必要があります。それは魔法では起こりません。