Как я могу получить будущее от boost::asio::post?
Я использую Boost 1.66.0, в котором ASIO имеет встроенную поддержку для взаимодействия с фьючерсами (и в течение некоторого времени сейчас). Примеры, которые я видел в Интернете, показывают, как добиться этого чисто при использовании сетевых функций, таких как async_read, async_read_some и т. д. Это делается путем предоставления boost::asio::use_future вместо обработчика завершения, который заставляет инициирующую функцию возвращать future как и ожидалось.
Какой тип объекта мне нужно предоставить или обернуть в мою функцию, чтобы получить то же поведение от boost::asio::post?
Моя цель публикации работы состоит в том, чтобы выполнить ее в контексте цепочки, но в противном случае дождаться завершения работы, чтобы я мог получить поведение, которое я хочу делать:
std::packaged_task<void()> task( [] { std::cout << "Hello world\n"; } );
auto f = task.get_future();
boost::asio::post(
boost::asio::bind_executor(
strand_, std::move( task ) ) );
f.wait();
но в соответствии с boost::asio документация, тип возврата для boost::asio::post выводится так же, как и для таких функций, как boost::asio::async_read Я чувствую, что должен быть более хороший способ избежать промежуточного packaged_task, В отличие от async_read нет никакой "другой работы" post так что просто boost::asio::use_future не имеет смысла, но мы могли бы определить async_result черта, чтобы получить такое же поведение для почты.
Есть ли обертка или что-то, что имеет необходимые черты, определяющие поведение, которое я хочу, или мне нужно определить это самому?
3 ответа
Какой тип объекта мне нужно предоставить или обернуть в мою функцию, чтобы получить то же поведение от
boost::asio::post?
Ты не можешь post это пустая операция. Так что единственный вариант добиться этого с post на самом деле использовать упакованное задание.
Настоящий вопрос
Это было спрятано в части "как получить такое же поведение" (только не из post):
template <typename Token>
auto async_meaning_of_life(bool success, Token&& token)
{
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);
if (success)
handler(error_code{}, 42);
else
handler(asio::error::operation_aborted, 0);
return result.get ();
}
Вы можете использовать его с будущим:
std::future<int> f = async_meaning_of_life(true, asio::use_future);
std::cout << f.get() << "\n";
Или вы можете просто использовать обработчик:
async_meaning_of_life(true, [](error_code ec, int i) {
std::cout << i << " (" << ec.message() << ")\n";
});
Простая демонстрация: Live On Coliru
Расширенная демоверсия
Тот же механизм распространяется на сопрограммы поддержки (с или без исключений). Там немного другой танец с async_result для Asio pre-boost 1.66.0.
Смотрите все различные формы вместе здесь:
#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_yield_catch: Answer: 42
using_future: Answer: 42
using_yield_catch: Caught: Operation canceled
using_future: Answer: using_future: Caught: Operation canceled
using_handler: Result: Success
using_handler: Answer: 42
using_handler: Result: Operation canceled
using_handler: Answer: 0
Идея @MartiNitro с стала частью библиотеки: теперь вы можете просто опубликовать
packaged_taskи волшебным образом вернет свое будущее:
auto f = post(strand_, std::packaged_task<int()>(task));
#include <boost/asio.hpp>
#include <iostream>
#include <future>
using namespace std::chrono_literals;
int task() {
std::this_thread::sleep_for(1s);
std::cout << "Hello world\n";
return 42;
}
int main() {
boost::asio::thread_pool ioc;
auto strand_ = make_strand(ioc.get_executor());
auto f = post(strand_, std::packaged_task<int()>(task));
// optionally wait for future:
f.wait();
// otherwise .get() would block:
std::cout << "Answer: " << f.get() << "\n";
ioc.join();
}
Отпечатки
Hello world
Answer: 42
Это то, что я придумал, это, по сути, обертывает asio::postи вставляет пару обещание / будущее. Думаю, его тоже можно адаптировать к вашим потребностям.
// outer scope setup
asio::io_context context;
asio::io_context::strand strand(context);
std::future<void> async_send(tcp::socket& socket, std::string message) {
auto buffered = std::make_shared<std::string>(message);
std::promise<void> promise;
auto future = promise.get_future();
// completion handler which only sets the promise.
auto handler = [buffered, promise{std::move(promise)}](asio::error_code, std::size_t) mutable {
promise.set_value();
};
// post async_write call to strand. Thas *should* protecte agains concurrent
// writes to the same socket from multiple threads
asio::post(strand, [buffered, &socket, handler{std::move(handler)}]() mutable {
asio::async_write(socket, asio::buffer(*buffered), asio::bind_executor(strand, std::move(handler)));
});
return future;
}
Обещание можно переместить, не делая недействительным будущее.
В соответствии с вашим сценарием это может быть примерно так:
template<typename C>
std::future<void> post_with_future(C&& handler)
{
std::promise<void> promise;
auto future = promise.get_future();
auto wrapper = [promise{std::move(promise)}]{ // maybe mutable required?
handler();
promise.set_value();
};
// need to move in, cause the promise needs to be transferred. (i think)
asio::post(strand, std::move(wrapper));
return future;
}
Я был бы рад получить отзывы об этих строках, потому что я сам все только учусь:)
Надеюсь на помощь, Марти