boost::asio::spawn 收益率作为回调

Question

我正在尝试使用 boost::asio::spawn 协程重写一个项目。项目的某些部分无法更改。比如存储协议库也是用boost::asio写的，但是没有协程。

问题是如何将yield_context 转换为普通回调（boost::function 对象或经典函子）。

这就是我们在存储库 API 中的内容：

void async_request_data(uint64_t item_id, boost::function< void(Request_result *) > callback);

从示例中我们知道，asio yield 上下文可以这样使用：

    my_socket.async_read_some(boost::asio::buffer(data), yield);

在这种情况下，boost::asio::yield_context 对象用作 async_read_some 的回调。我想将 yield 对象作为第二个参数传递给async_request_data，这样我就可以以同步的方式使用它。

如何做到这一点？我认为可以通过一些代理对象实现，可能使用基于 asio_handler_invoke 的方法。但我很难看到如何做到这一点。

Answer 1

看起来这个特性的最佳文档可以在 boost asio 作者编写的 C++ 标准提案中找到：

N4045 – Library Foundations for Asynchronous Operations, Revision 2

请参阅第 9.1 节：

handler_type_t<CompletionToken, void(error_code, size_t)>   #3
  handler(std::forward<CompletionToken>(token));

3：完成标记被转换为处理程序，即要调用的函数对象 当异步操作完成时。签名指定参数 这将被传递给处理程序。

我猜在你的情况下，CompletionToken 模板参数实际上是boost::asio::yield_context 和handler_type 将其转换为回调对象。

---

这是第 9.1 节中更新的代码以调用您的 async_request_data 函数：

template <class CompletionToken>
auto async_foo(uint64_t item_id, CompletionToken&& token)
{
  handler_type_t<CompletionToken, void(Request_result *)>
    handler(std::forward<CompletionToken>(token));

  async_result<decltype(handler)> result(handler);  

  async_request_data(item_id, handler);

  return result.get();  
}

Answer 2

感谢@PSIAlt 和@free_coffee，我知道如何在堆栈式协程中使用回调函数。

这是一个简单的示例，仅适用于 asio 新手（比如我：D）

https://gist.github.com/chenfengyuan/4d764b0bca82a42c05a9

#include <iostream>
#include <boost/asio.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/asio/spawn.hpp>
#include <memory>

void bar(boost::asio::io_service &io, std::function<void()> cb){
    auto ptr = std::make_shared<boost::asio::deadline_timer>(io, boost::posix_time::seconds(1));
    ptr->async_wait([ptr, cb](const boost::system::error_code&){cb();});
}

template<typename Handler>
void foo(boost::asio::io_service &io, Handler && handler){
    typename boost::asio::handler_type<Handler, void()>::type handler_(std::forward<Handler>(handler));
    boost::asio::async_result<decltype(handler_)> result(handler_);
    bar(io, handler_);
    result.get();
    return;
}

int main()
{
  boost::asio::io_service io;
  boost::asio::spawn(io, [&io](boost::asio::yield_context yield){
      foo(io, yield);
      std::cout << "hello, world!\n";
  });

  io.run();

  return 0;
}

Answer 3

---

非常感谢 free_coffe 我成功地完成了这项工作。为我的案例发布解决方案，可能有人需要它。

template <class CompletionToken>
RequestResult async_foo(Packet &pkt, CompletionToken&& token) {
   typename boost::asio::handler_type< CompletionToken, void(RequestResult) >::type handler( std::forward<CompletionToken>(token) );
  boost::asio::async_result<decltype(handler)> result(handler);
  storage_api->writePacket(pkt, handler);
  return result.get();
}

稍后我们可以使用这个代理：

RequestResult res = async_foo(pkt, std::forward<boost::asio::yield_context>(yield) );