Как установить код ошибки в asio :: yield_context
Я хотел бы создать асинхронную функцию, которая принимает в качестве последнего аргумента 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 и выполнить его. Но это решение кажется в лучшем случае неудобным.
Есть ли другой способ?
Решение
Asio использует 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
Другие решения
Других решений пока нет …
detector