についてboost :: asio :: io_service :: run into multithread

Question

boost docは、io_serviceがスレッド間で任意の方法で作業を分散する可能性があると言います。つまり、TCPソケットを使用しているときにデータが混乱する可能性がありますか？私の受信ハンドラはスレッド間で任意の方法で配布される可能性があるためです。

Answer 1

ブーストio_serviceを使用してasync_readまたはreadをスケジュールすると、ソケットで動作します。 socket->read(...)またはread(socket ...)のいずれかを使用します。ドキュメントを調べると、読み込み、バイト数、または一致条件の終了基準を受け入れるバリエーションがいくつかあります。これを使用すると、20バイトのデータが10バイトで1つのスレッドに読み込まれ、そのスレッドがデータを処理している間に次の20バイトが別のスレッドに渡る接続ができます。いくつかのケースがありますが、通常は各スレッドがパケット全体を読み取る必要があります。

一度に1つのスレッドだけがソケットからioを処理するようにしたい場合は、コールバックをstrandにラップすることができます。これは、そのように見えるもののかなり一般的な例です。

boost::asio::async_read(socket, 
         buffer(*responseBuffer), 
         transfer_all(), 
         strand.wrap(boost::bind(&YourClass::handleRead, 
               this, /*or use shared_from_this*/ 
               placeholders::error)));