В чем причина долгого исполнения моего асинхронного HTTP клиента?

Question

[HamsterGamer]

Всем привет, необходимо реализовать асинхронный HTTP клиентик, который имея список url'ов трекеров должен вернуть первый полученный HTTP response от любого первого ответившего. Немного переписав пример из оф доки - https://www.boost.org/doc/libs/1_76_0/doc/html/boo... и добавив туда работу с boost::future/boost::promise я написал следующий код:
https://pastebin.com/hAG2k3rd
Изменения внесенные в пример: в структуре client теперь имеется promise, у клиентского кода же есть future от него, и он, используя бустовую функцию when_any пытается получить самый быстрый и валидный фьючерс. When_any вернет вектор фьючерсов, где первый будет гарантированно готов к обработке, внутри обработчика я проверяю результат фьючерса на исключение и если оно есть, то запускаю процедуру заново, но уже с частью фьючерсов которые еще не были обработаны.

В целом он вроде как даже работает, но почему-то тормозит (именно вся программа, то есть поток main'a и поток где выполняется io_service::run застывают) на строчке под номером 228 "result.set_value(any_res->get());", и я не понимаю в чем причина такого поведения, прошу помочь разобраться! Заранее благодарю!

Comments

[Евгений Шатунов]

HamsterGamer , у тебя слишком общий вопрос. Слишком большой код, слишком неконкретная формулировка.
Это больше напоминает задание, а не вопрос. С подобными заданиями тебе стоит обращаться на фриланс.
Размещение заданий на Тостере нарушает П5.12 регламента.

[HamsterGamer]

Евгений Шатунов, нет это не задание (я итак воссоздал ошибку локально на примере буста, сократить код сильнее не могу), мне нужно понять конкретно по коду в чем причина торможения. Ну и вроде как я догадался, проблема кажется в очень долгом timeout'е у async_connect'a (который вызывается после io_service::run), я почему-то ожидал что он куда-то делегирует операцию подключения, а сам выполнит лишь хэндлер когда сокет подключится. Но судя по всему я ошибался.

[Евгений Шатунов]

HamsterGamer, позволь уточнить только одну штуку.
Размещая свой вопрос, каких конкретных действий ты ожидаешь от других людей? Чтобы твой код взяли к себе, изучили, потратили свое собственное время и показали тебе где и почему происходит замедление? Или ты ожидаешь чего-то другого? Будет хорошо если ты изложишь свои ожидания.

[HamsterGamer]

Евгений Шатунов, ну мне кажется что опытному пользователю asio достаточно будет взглянуть на код, чтобы ответить чего я не понял/сделал неправильно. И повторю еще раз, это искусственное воссоздание проблемы, программное замедление у меня из-за недостатка знаний, поэтому как мне кажется, вопрос я задал адекватно.

[Евгений Шатунов]

HamsterGamer, хорошо. Я в таком случае приношу свои извинения за то что неправильно оценил текст твоего вопроса.

Answer 1

[HamsterGamer]

Вроде как я разобрался, в литературе Энтони Уильямса when_any (из experimental std) работает ровно как я описал выше, то есть когда будет готов хотя бы 1 фьючерс он вернет вектор фьючерсов в отсортированном виде так, чтобы сначала шли готовые (то есть begin должен быть 100% is_ready), в бустовой же версии готовый фьючерс будет лежать на своем месте, а не в начале.
И доставать его нужно как-то так:

...(boost::future<std::vector<boost::future<std::string>>> result_args) {
                auto results = result_args.get();
                auto any_res = results.begin();
                for (; any_res != results.end(); any_res++){
                    if (any_res->is_ready())
                        break;
                }
...

Comments

[cunion]

Можете заменить код поиска готового фуьючерса на этот

auto any_res = std::find_if(results.begin(), results.end(), [](const boost::future<std::string>& f)
		{
			return f.is_ready();
		});