Как подключить ASIO, блокирующее IO_CONTEXT с помощью CORUTINES ⇐ C++

[Anonymous]

Итак, я играю с Coroutines и сумел интегрировать стороннего клиента HTTP, в данном конкретном случае «Via-http-lib», для учебных целей, и он собирает и работает. То, что LIB обеспечивает не блокирующего HTTP-клиента, работающего на ASIO под капотом и использует обратные вызовы для обработки событий. Но проблема в том, что я не могу сделать несколько запросов на получение GET через друг друга, несмотря на то, что они их. Проблема не в моей реализации Coroutine, если я придумываю сервер локальным ответом, который он работает. Я считаю, что проблема в том, что ASIO S IO_CONTEXT блокирует до тех пор, пока активное соединение активно. В этом через - lib соединение закрыто, когда нет данных больше. Это должно быть в какой -то момент. Тем не менее, он никогда не достигает 2 -го CO_AWAIT httpclient :: get . Точнее, он никогда не достигает кода сразу после io_context.run () . Я попытался запустить co_await req (и, следовательно, в конечном итоге io_context ) в другом потоке, чего было недостаточно. Интересно, что я узнал, что если я добавлю еще один переключатель потока, например, Оберните Co_await req между 2-й переключающей потоком CO_AWAITS, похоже, я могу запустить столько запросов, сколько захочу, и даже если цикл 10000 получает запросы, у меня нет более 4 потоков (согласно менеджеру задач Windows). Но все же это не может быть правильным решением. Я хотел бы иметь одно резьбое решение. Весь смысл асинхронного и критиков. Я думал, что весь смысл ASIO заключается в том, чтобы обеспечить асинхронную работу. Но примеры ASIO, которые я обнаружил, - это просто процедурные программы, выполненные на высшем уровне, например, один вызов с одним вызовом или основной во время цикла. Однако я вызываю ASIO глубоко внутри моей объектно -ориентированной программы и не могу перевести соответствующее использование ... < /p>
HttpResponseTask HttpClient::GET(const std::string& uri) const
{
auto req = HttpRequest(host_, uri);
co_await continue_on_new_thread();
auto data = co_await req;
co_await continue_on_new_thread();
co_return data;
}
< /code>
co_await req использует мою ожидаемую реализацию httprequest:
std::coroutine_handle HttpRequest::await_suspend(std::coroutine_handle h)
{
std::osyncstream(std::cout) remote_address();
connection->send(std::move(response), std::move(response_body));
}
else
std::cerr

Подробнее здесь: https://stackoverflow.com/questions/795 ... coroutines