Может ли io_context :: strand гарантировать порядок между обработчиком завершения async_ * и пользовательским функтором? - PullRequest
Новая
       24

Может ли io_context :: strand гарантировать порядок между обработчиком завершения async_ * и пользовательским функтором?

0 голосов
/ 28 ноября 2018

У меня есть такая ситуация, когда мне нужно подготовить операцию async_read к чтению, прежде чем я вызову пользовательскую функцию, которая отправляет что-то в контрагент веб-сокета.У меня есть обработчик завершения async_read, завернутый в ту же цепочку, куда я отправляю свой функтор.

Проблема в том, что иногда on :: read не вызывается, поэтому в принципе я думаю, что writeFromCounterpart () вызываетсядо того, как ws_1 был в состоянии «чтения».

Насколько я понимаю, strand гарантирует порядок между обработчиками завершения, но я не понимаю, гарантирует ли то, что операция async_ * "готова" (работает в потоке и читает) перед продолжением другой операции изпряди ФИФО.

Полный код ниже: Когда я запускал его, большую часть времени я видел следующий вывод: 

on_read called
Run 2 Handlers

Я также мог видеть следующее несколько раз (~ 1 в20 в стрессовом состоянии), 

on_write called
Run 1 Handlers

Я никогда не видел ни on_write, ни on_read

Код: 

#include <boost/asio.hpp>
#include <boost/beast/websocket.hpp>
#include <boost/beast/http.hpp>
#include <boost/beast/core.hpp>
#include <string>

using tcp = boost::asio::ip::tcp;               // from <boost/asio/ip/tcp.hpp>
namespace websocket = boost::beast::websocket;  // from <boost/beast/websocket.hpp>

boost::beast::multi_buffer buffer;
boost::asio::io_context ioc_1;
boost::asio::io_context ioc_2;
websocket::stream<tcp::socket> ws_1(ioc_1);
websocket::stream<tcp::socket> ws_2(ioc_2);


void on_write(boost::system::error_code, std::size_t) {
  std::cout << "on_write called" << std::endl << std::flush;
}

void writeFromCounterpart() {
  ws_2.async_write(boost::asio::buffer(std::string("Hello")), on_write);
}

void on_read(boost::system::error_code, std::size_t) {
  std::cout << "on_read called" <<std::endl << std::flush;
}

int main() {
  std::thread t([](){
    auto const address = boost::asio::ip::make_address("127.0.0.1");
    tcp::acceptor acceptor{ioc_2, {address, 30000}};
    tcp::socket socket{ioc_2};

    acceptor.accept(socket);
    websocket::stream<tcp::socket> ws{std::move(socket)};
    ws.accept();
    ws_2 = std::move(ws);
    ioc_2.run();
  });
  t.detach();

  // allow acceptor to accept
  std::this_thread::sleep_for(std::chrono::milliseconds(200));

  tcp::resolver resolver_(ioc_1);
  boost::asio::io_context::strand strand_(ioc_1);
  auto const results = resolver_.resolve("127.0.0.1", "30000");
  boost::asio::connect(ws_1.next_layer(), results.begin(), results.end());
  ws_1.handshake("127.0.0.1", "/");

  ws_1.async_read(buffer, strand_.wrap(on_read));
  strand_.post(writeFromCounterpart);
  auto handlers = ioc_1.run_for(std::chrono::milliseconds(5000));
  std::cout << "Run " + std::to_string(handlers) + " Handlers" << std::endl << std::flush;
}

1 Ответ

0 голосов
/ 28 ноября 2018

Краткий ответ: да .

Документация для этого здесь:

Проблема в том, что иногда, когда я запускаю этот поток, on :: read не вызывается, поэтому в основном я думаю, что SendSomethingOnTheWs вызывается до того, как ws_ находился в состоянии «чтения».

Почему это имеет значение?Потоковые сокеты (ws или другие) ведут себя как потоки.Если сокет был открыт , данные будут просто буферизованы.

...