boost :: asio :: spawn yield作为回调

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产量上下文可以像这样使用：

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

在这种情况下，boost::asio::yield_context对象用作async_read_some的回调。我想通过一个收益对象作为async_request_data的第二个参数，所以我可以以同步的方式使用它。

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

Answer 1

貌似此功能的最好的文档可以在C中找到++由升压ASIO作者撰写标准提案：

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: The completion token is converted into a handler, i.e. a function object to be called when the asynchronous operation completes. The signature specifies the arguments that will be passed to the handler.

我想你的情况下，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

---

十分感谢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)); 

Answer 3

感谢@PSIAlt和@free_coffee我知道如何在stackful协程使用回调函数。

这里只是对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; 
}