Boost.Asio: Any_completion_handler и связанный с ним исполнитель.C++

Программы на C++. Форум разработчиков
Ответить
Anonymous
 Boost.Asio: Any_completion_handler и связанный с ним исполнитель.

Сообщение Anonymous »

Я хочу реализовать свою собственную асинхронную инициирующую функцию и использовать оболочку стирания типа boost::asio::any_completion_handler. Предполагая, что я хочу сохранить обработчик завершения на будущее, как мне гарантировать, что обработчик завершения будет выполнен в желаемом контексте выполнения? Эта концепция практически не описана в документации и приведенных примерах.
Приведенный ниже код соответствует рекомендациям по реализации пользовательских асинхронных операций и разделяет реализацию с помощью оболочки стирания типа boost::asio::any_completion_handler.
Я уже экспериментировал с различными альтернативами. Если я напрямую выполняю завершение_обработчика через его оператор функции, связанный исполнитель не учитывается. Однако попытка опубликовать обработчик завершения с использованием связанного исполнителя уже терпит неудачу во время компиляции. Должен ли я использовать Execute(func) соответствующего исполнителя для выполнения обработчика завершения? Как это повлияет на поведение во время выполнения, поскольку оно не публикуется, а скорее выполняется?
PS.: Я заметил, что пересылка экземпляра boost::asio::any_completion_handler с пользовательским исполнителем в существующую библиотечную функцию (например, boost::asio::steady_timer::async_wait) работает так, как ожидалось. Нужно ли мне копировать здесь детали реализации для моей собственной асинхронной операции?
#include
#include

void async_request_impl(
boost::asio::any_completion_handler completion_handler)
{
// Option 1:
// immediate execution of completion handler works but doesn't consider executor
std::move(completion_handler)(boost::system::error_code{});

// Option 2:
// doesn't compile as boost::asio::any_completion_executor doesn't
// satisfy requirements for boost::asio::post
// auto exec = boost::asio::get_associated_executor(completion_handler);
// boost::asio::post(
// exec,
// [completion_handler = std::move(completion_handler] () mutable {
// std::move(completion_handler)(boost::system::error_code{});
// }
// );
}

template
auto async_request(CompletionToken&& token)
{
auto init = [](auto completion_handler) {
async_request_impl(std::move(completion_handler));
};

return boost::asio::async_initiate(init, token);
}

int main()
{
boost::asio::io_context ioContext;

// create strand and bind execution of completion token to it
auto strand = boost::asio::make_strand(ioContext);
async_request(boost::asio::bind_executor(strand, [](auto) {
std::cout

Подробнее здесь: https://stackoverflow.com/questions/797 ... d-executor
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «C++»