boost :: asio :: yield_context: неожиданное исключение принудительного_решения

Короче говоря, вам нужно создать копию обработчика, например, разместив ее в io_serviceпрежде чем пытаться получить async_result чтобы поддержать сопрограмму.

Boost.Asio предотвращает бессрочную приостановку сопрограммы на неопределенный срок, уничтожая сопрограмму, в результате чего стек сопрограммы разматывается. Объект сопрограммы бросит boost::coroutines::detail::forced_unwind во время его разрушения, в результате чего подвесной стек раскручивается. Asio выполняет это:

• yield_context CompletionToken поддерживает weak_ptr в сопрограмму.
• Когда специализированный handler_type::type обработчик построен, он получает shared_ptr для сопрограммы через CompletionToken’s weak_ptr, Когда обработчик передается как обработчик завершения асинхронным операциям, обработчик и его shared_ptr копируются. Когда обработчик вызывается, он возобновляет сопрограмму.
• При вызове async_result::get(), специализация сбросит сопрограмму shared_ptr принадлежит обработчику, который был передан async_result во время строительства, а затем дать сопрограмму.

Вот попытка проиллюстрировать выполнение кода. Пути в | указать активный стек, : указывает на приостановленный стек, а стрелки используются для обозначения передачи управления:

boost::asio::io_service io_service;
boost::asio::spawn(io_service, &my_timer);
`-- dispatch a coroutine creator
into the io_service.
io_service.run();
|-- invoke the coroutine entry
|   handler.
|   |-- create coroutine
|   |   (count: 1)
|   |-- start coroutine        ----> my_timer()
:   :                                |-- create handler1 (count: 2)
:   :                                |-- create asnyc_result1(handler1)
:   :                                |-- timer.async_wait(handler)
:   :                                |   |-- create handler2 (count: 3)
:   :                                |   |-- create async_result2(handler2)
:   :                                |   |-- create operation and copy
:   :                                |   |   handler3 (count: 4)
:   :                                |   `-- async_result2.get()
:   :                                |       |-- handler2.reset() (count: 3)
|   `-- return                 <---- |       `-- yield
|       `-- ~entry handler           :
|           (count: 2)               :
|-- io_service has work (the         :
|   async_wait operation)            :
|   ...async wait completes...       :
|-- invoke handler3                  :
|   |-- resume                 ----> |-- async_result1.get()
:   :                                |   |--  handler1.reset() (count: 1)
|   `-- return                 <---- |   `-- yield
|       `-- ~handler3                :       :
|           |  (count: 0)            :       :
|           `-- ~coroutine()   ----> |       `-- throw forced_unwind

Чтобы исправить эту проблему, handler должен быть скопирован и вызван через asio_handler_invoke() когда пришло время возобновить сопрограмму. Например, следующее опубликует обработчик завершения¹ в io_service это вызывает копию handler:

timer.async_wait (handler);

timer.get_io_service().post(
std::bind([](decltype(handler) handler)
{
boost::system::error_code error;
// Handler must be invoked through asio_handler_invoke hooks
// to properly synchronize with the coroutine's execution
// context.
using boost::asio::asio_handler_invoke;
asio_handler_invoke(std::bind(handler, error), &handler);
}, handler)
);
return result.get ();

Как продемонстрировано Вот, с этим дополнительным кодом, вывод становится:

my_timer enter
my_timer returns

_{1. Код обработчика завершения, вероятно, можно немного очистить, но, как я отвечал как возобновить стог сопрограммы Boost.Asio из другого потока, Я заметил, что некоторые компиляторы выбирают неправильно asio_handler_invoke крюк.}