@ sehe Отлично, спасибо большое. вы сделали мой день ;-)

ел бы создать асинхронную функцию, которая принимает в качестве последнего аргумента boost :: asio :: yield_context. Например.:

int async_meaning_of_life(asio::yield_context yield);

Я также хотел бы согласиться с тем, как Asio возвращает коды ошибок. То есть, если пользователь делает:

int result = async_meaning_of_life(yield);

и функция терпит неудачу, то он бросаетsystem_error исключение. Но если пользователь делает:

boost::error_code ec;
int result = async_meaning_of_life(yield[ec]);

Тогда - вместо броска - ошибка возвращается вec.

Проблема в том, что при реализации функции я не могу найти чистый способ проверить, использовался ли оператор [] или нет, и установить его, если так. Мы придумали что-то вроде этого:

inline void set_error(asio::yield_context yield, sys::error_code ec)
{
    if (!yield.ec_) throw system_error(ec);
    *(yield.ec_) = ec;
}

Но это глупо, потому чтоyield_context::ec_ являетсяобъявлен частным (хотя только в документации).

Еще один способ сделать это - конвертироватьyield возражать вasio::handler_type и выполнить его. Но это решение кажется в лучшем случае неудобным.

Есть ли другой способ?

Ответы на вопрос(1)

async_result прозрачно обеспечитьuse_future, yield_context или обработчики завершения в его интерфейсах API.

Вот как выглядит шаблон:

template <typename Token>
auto async_meaning_of_life(bool success, Token&& token)
{
    typename asio::handler_type<Token, void(error_code, int)>::type
                 handler (std::forward<Token> (token));

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

    if (success)
        handler(42);
    else
        handler(asio::error::operation_aborted, 0);

    return result.get ();
}
Обновить

Начиная с Boost 1.66 паттернпридерживается предложенного интерфейса для стандартизации:

    using result_type = typename asio::async_result<std::decay_t<Token>, void(error_code, int)>;
    typename result_type::completion_handler_type handler(std::forward<Token>(token));

    result_type result(handler);
Комплексная демонстрация

Показывает, как использовать его с

коро и урожайность [ес]Коро и доходность + исключениястанд :: будущееобработчики завершения

Жить на Колиру

#define BOOST_COROUTINES_NO_DEPRECATION_WARNING 
#include <iostream>
#include <boost/asio.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/asio/use_future.hpp>

using boost::system::error_code;
namespace asio = boost::asio;

template <typename Token>
auto async_meaning_of_life(bool success, Token&& token)
{
#if BOOST_VERSION >= 106600
    using result_type = typename asio::async_result<std::decay_t<Token>, void(error_code, int)>;
    typename result_type::completion_handler_type handler(std::forward<Token>(token));

    result_type result(handler);
#else
    typename asio::handler_type<Token, void(error_code, int)>::type
                 handler(std::forward<Token>(token));

    asio::async_result<decltype (handler)> result (handler);
#endif

    if (success)
        handler(error_code{}, 42);
    else
        handler(asio::error::operation_aborted, 0);

    return result.get ();
}

void using_yield_ec(asio::yield_context yield) {
    for (bool success : { true, false }) {
        boost::system::error_code ec;
        auto answer = async_meaning_of_life(success, yield[ec]);
        std::cout << __FUNCTION__ << ": Result: " << ec.message() << "\n";
        std::cout << __FUNCTION__ << ": Answer: " << answer << "\n";
    }
}

void using_yield_catch(asio::yield_context yield) {
    for (bool success : { true, false }) 
    try {
        auto answer = async_meaning_of_life(success, yield);
        std::cout << __FUNCTION__ << ": Answer: " << answer << "\n";
    } catch(boost::system::system_error const& e) {
        std::cout << __FUNCTION__ << ": Caught: " << e.code().message() << "\n";
    }
}

void using_future() {
    for (bool success : { true, false }) 
    try {
        auto answer = async_meaning_of_life(success, asio::use_future);
        std::cout << __FUNCTION__ << ": Answer: " << answer.get() << "\n";
    } catch(boost::system::system_error const& e) {
        std::cout << __FUNCTION__ << ": Caught: " << e.code().message() << "\n";
    }
}

void using_handler() {
    for (bool success : { true, false })
        async_meaning_of_life(success, [](error_code ec, int answer) {
            std::cout << "using_handler: Result: " << ec.message() << "\n";
            std::cout << "using_handler: Answer: " << answer << "\n";
        });
}

int main() {
    asio::io_service svc;

    spawn(svc, using_yield_ec);
    spawn(svc, using_yield_catch);
    std::thread work([] {
            using_future();
            using_handler();
        });

    svc.run();
    work.join();
}

Печать:

using_yield_ec: Result: Success
using_yield_ec: Answer: 42
using_yield_ec: Result: Operation canceled
using_yield_ec: Answer: 0
using_future: Answer: 42
using_yield_catch: Answer: 42
using_yield_catch: Caught: Operation canceled
using_future: Caught: Operation canceled
using_handler: Result: Success
using_handler: Answer: 42
using_handler: Result: Operation canceled
using_handler: Answer: 0

Примечание: для простоты я не добавил синхронизацию вывода, поэтому выходные данные могут смешиваться в зависимости от порядка выполнения во время выполнения

См. Например это отличная демонстрация того, как использовать его для расширения библиотеки с помощью собственного шаблона результатов асинхронного преобразованияboost :: asio с boost :: unique_future

 Amin Roosta28 янв. 2018 г., 14:43
Это не работает в boost 1.66, выдает ошибку компиляции.
 Amin Roosta29 янв. 2018 г., 14:23
@ sehe Отлично, спасибо большое. вы сделали мой день ;-)
 sehe22 окт. 2017 г., 12:29
Считаете этот ответ подтверждением своих страхов? То, что вы хотите сделать, будет оставаться неуклюжим, пока кто-то не придет с новой информацией (или API библиотеки не будет расширен).
 Peter Jankuliak26 окт. 2017 г., 16:27
Извините за задержку. Я думаю, что если вы измените свой ответ, чтобы явно упомянуть где-то в начале, что в настоящее время это невозможно, я буду рад пометить его как ответ, пока кто-нибудь не докажет нам неправоту.
 Peter Jankuliak22 окт. 2017 г., 10:01
Спасибо @sehe, но это "преобразоватьyield возражать вasio::handlerРешение, которое я упомянул в вопросе. Я не пытаюсь создать универсальную асинхронную функцию, которая поддерживает обработчики, фьючерсы и сопрограммы. Напротив, я стараюсь как можно дольше придерживаться сопрограмм для ясности кода.

Ваш ответ на вопрос