使用升壓異步API的多線程

Question

關於這個帖子： Why do I need strand per connection when using boost::asio?

我專注於這個聲明對於異步調用： 「不過，這是不是安全的多線程撥打電話同時」

此示例： http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/example/cpp11/chat/chat_client.cpp

如果我指的是主要爲「線程1」，並且產生的線程T作爲「線程2」，則好像線程1是調用ASYNC_WRITE（假設沒有write_in_progress），而線程2是調用ASY nc_read。我錯過了什麼？

Answer 1

在官方chat example，chat_client::write()推遲通過io_service::post()工作的io_service，這將：

• 要求，即io_service通過當前調用線程執行指定的處理程序poll()，poll_one()，run()，或run_one()功能io_service
• 不允許在調用函數內調用給定的處理程序（例如，chat_client::write()）

由於只有一個線程正在運行io_service，並且所有套接字的讀取，寫入和關閉操作僅從發佈到io_service的處理程序啓動，所以該程序滿足socket的線程安全要求。

class chat_client 
{ 
    void write(const chat_message& msg) 
    { 
    // The nullary function `handler` is created, but not invoked within 
    // the calling function. `msg` is captured by value, allowing `handler` 
    // to append a valid `msg` object to `write_msgs_`. 
    auto handler = [this, msg]() 
     { 
     bool write_in_progress = !write_msgs_.empty(); 
     write_msgs_.push_back(msg); 
     if (!write_in_progress) 
     { 
      do_write(); 
     } 
     }; 

    // Request that `handler` be invoked within the `io_service`. 
    io_service_.post(handler); 
    } 
};