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

[Anonymous]

Итак, я играю с Coroutines и сумел интегрировать стороннего клиента
http, в данном конкретном случае «Via-http-lib», для изучения
, и он компилирует и работает. Что LIB предоставляет неблокирующую HTTP
клиент, основанный на ASIO под капотом и использует обратные вызовы для события
handling.
Цель моей программы обучения было то, как интегрировать эти обратные вызовы в
coroutines, так что я могу сделать Async Operations Synchron, и я считаю, что
< /> < /> < /pry-press < /pry. Не могу сделать несколько запросов GET через друг друга, несмотря на
co_awaiting< /code> Они. Я полагаю, что проблема в том, что ASIO S IO_CONTEXT является
, блокирующим, пока соединение-
Aactive.
В этом через - lib, соединение закрыто, когда нет данных. Это
должно иметь место в какой -то момент. Тем не менее, он никогда не достигает 2 -го
co_await HttpClient::GET. Точнее, он никогда не достигает кода непосредственно
после io_context.run () < /code>. < /P>

Я пытался запустить Co_await req < /code> (и, следовательно, в конечном итоге io_context < /code>) в другой потоке
, что было недостаточно. Интересно, что я узнал, что если я добавлю еще один переключатель по потоке
, например, Оберните Co_await req < /code> между 2
Co_awaits, похоже, я могу запустить столько же, сколько и я
, и даже если цикл 10000 получает запросы, у меня нет более 4 потоков
(согласно диспетчере задач Windows). Но все же это не может быть правильным решением.
Я хотел бы иметь одно резерное решение. Весь смысл Async и
coroutines.
, к сожалению, у меня есть 0 опыта с Asio, и мне интересно, как его правильно интегрировать
в мой случай использования. Я думал, что весь смысл ASIO заключается в том, чтобы обеспечить Async
работать. Но примеры ASIO, которые я обнаружил, - это просто процедурные программы, выполненные на верхнем уровне
, например, один вызов с одним вызовом или основной цикл. Однако я
alf 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