asio use_future вместо yield [ec]

Question

я хочу создать контейнер фьючерсов, каждое будущее является недействительным результатом задачи, чтобы я мог использовать wait_for_any для контейнера, каждая задача - сопрограмма, которую я сейчас реализую с помощью yield_context, и внутри этой сопрограммы есть инициирующая функция, которая возвращает e c и результат, где я использую e c для анализа результата. Затем вызывается другая сопрограмма, передает тот же yield_context.
Я хочу знать, как создать этот дизайн.
и если я буду использовать use_future, как Могу ли я передать код ошибки в e c, не выбрасывая его, если нет другого способа, кроме как выбросить его, в этом случае я поставлю попытку и поймал асин c инициирующие функции.
все эти задачи будут опубликованы, порождены ... на asio io_service.
это мои основные части кода:
это порождение задачи

boost::asio::spawn(GetServiceReference(), boost::bind(&HTTPRequest::Execute, boost::placeholders::_1, m_HttpClient_request_name, Get_mHTTPClient_Responses_Map()));

и это сопрограмма с помощью yield_context

void HTTPRequest::Execute(boost::asio::yield_context yield_r, std::string request_name, std::map<std::string, boost::shared_ptr<HTTPResponse>>& mHTTPClient_Responses_Map)
{
    resolver_iterator iterator_connect = boost::asio::async_connect(mSock, iterator_resolve, yield_r[ec]);
}

и внутри Execute мы используем e c для анализа

if (ec == boost::system::errc::errc_t::success){}

и здесь мы запускаем другую сопрограмму, передавающую тот же yield_context

SendRequest(yield_r);
}

Я хочу изменить это, чтобы у меня был контейнер фьючерсов для всех порожденных Execute, меня не волнуют результаты Execute, потому что я помещаю их в класс ответа Response.
Но мне нужен результат в будущем, поэтому что я могу использовать wait_any на контейнере.

Answer 1

Если вы можете изменить свою реализацию, используйте шаблон async_result.

Это позволяет использовать ваш метод с любым из подходов (обработчик завершения, контекст урожайности или use_future).

Я воспроизвожу автономный пример из здесь для вдохновения:

Комплексная демонстрация

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

• coro's и yield [ec]
• coro's и yield + исключения
• std :: future
• обработчики завершения

Live On Coliru

#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

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