c++ - 同步 boost ASIO : Asynchronous write,

Question

我有一个程序(客户端+服务器)可以正常工作:

boost::asio::write(this->socket_, boost::asio::buffer(message.substr(count,length_to_send)));

哪里socket_是boost::asio::ssl::stream<boost::asio::ip::tcp::socket>和 message是一个 std::string .

我想让它变得更好和非阻塞，所以我创建了一个可以替代它的函数，它的调用如下:

write_async_sync(socket_,message.substr(count,length_to_send));

这个函数的目的是:

1. 本质上使调用异步
2. 保持界面不变

我实现的功能只是简单的使用了promise/future来模拟sync行为，后面我会修改(生效后)为可取消:

std::size_t 
SSLClient::write_async_sync(boost::asio::ssl::stream<boost::asio::ip::tcp::socket>& socket, 
                            const std::string& message_to_send)
{
    boost::system::error_code write_error;
    std::promise<std::size_t> write_promise;
    auto write_future = write_promise.get_future();

    boost::asio::async_write(socket,
                             boost::asio::buffer(message_to_send), 
        [this,&write_promise,&write_error,&message_to_send]
        (const boost::system::error_code& error,
        std::size_t size_written)
        {
            logger.write("HANDLING WRITING");
            if(!error)
            {
                write_error = error;
                write_promise.set_value(size_written);
            }
            else
            {
                write_promise.set_exception(std::make_exception_ptr(std::runtime_error(error.message())));
            }
        });
    std::size_t size_written = write_future.get();
    return size_written;
}

问题:我无法使用异步功能。同步一个工作正常，但异步只是卡住并且永远不会进入 lambda 部分(写入永远不会发生)。我做错了什么？

---

编辑:我意识到使用 poll_one()使函数执行并继续进行，但我不明白。这就是我打电话的方式 run()对于 io_service (在启动客户端之前):

io_service_work = std::make_shared<boost::asio::io_service::work>(io_service);
io_service_thread.reset(new std::thread([this](){io_service.run();}));

基本上这些是shared_ptr .这是错误的吗？这种方式是否需要使用 poll_one() ？

Answer 1

回复。编辑:

你有 io_service::run()正确。这告诉我你在(完成)处理程序中阻止了 future 。显然，这会阻止 run()从推进事件循环。

---

@florgeng 问的问题不是你是否有 io_service实例。

问题是你是不是调用run() (或 poll() )适合异步操作进行。

此外，您已经可以使用future<>内置:

• http://www.boost.org/doc/libs/1_64_0/doc/html/boost_asio/overview/cpp2011/futures.html
• 示例:http://www.boost.org/doc/libs/1_64_0/doc/html/boost_asio/example/cpp11/futures/daytime_client.cpp

std::future<std::size_t> recv_length = socket.async_receive_from(
      boost::asio::buffer(recv_buf),
      sender_endpoint,
      boost::asio::use_future);