7

在阅读文档时，coroutine2我发现了一段很好的代码片段，展示了如何使用它asio

以下是文档中的代码供参考：

void session(boost::asio::io_service& io_service){
    // construct TCP-socket from io_service
    boost::asio::ip::tcp::socket socket(io_service);

    try{
        for(;;){
            // local data-buffer
            char data[max_length];

            boost::system::error_code ec;

            // read asynchronous data from socket
            // execution context will be suspended until
            // some bytes are read from socket
            std::size_t length=socket.async_read_some(
                    boost::asio::buffer(data),
                    boost::asio::yield[ec]);
            if (ec==boost::asio::error::eof)
                break; //connection closed cleanly by peer
            else if(ec)
                throw boost::system::system_error(ec); //some other error

            // write some bytes asynchronously
            boost::asio::async_write(
                    socket,
                    boost::asio::buffer(data,length),
                    boost::asio::yield[ec]);
            if (ec==boost::asio::error::eof)
                break; //connection closed cleanly by peer
            else if(ec)
                throw boost::system::system_error(ec); //some other error
        }
    } catch(std::exception const& e){
        std::cerr<<"Exception: "<<e.what()<<"\n";
    }
}

但是我在 asio 文档上找不到工作示例，并且尝试在 coliru 上编译此代码段会给我与相关的编译器错误yield

您是否知道coroutine2上面示例中使用的最小客户端/服务器实现？

4

2 回答 2

9

AFAIK boost.asio 仅支持 boost.coroutine，不支持 boost.coroutine2

于 2016-08-17T12:27:25.643 回答
4

这里给出了一个使用协程的基于 Boost.Asio 的服务器示例。

Boost.Coroutine 文档中显示的示例缺少boost::asio::spawn用于创建yield_context可作为异步处理程序传递的 a 的部分。

通过遵循#include内的链<boost/asio/spawn.hpp>，它似乎只包括 Boost.Coroutine v1。

于 2016-10-28T18:53:41.823 回答