172 похожих чатов

Подскажите пожалуйста, как идеоматично запустить набор tokio футур и подождать

их все? При этом нужно ограничить количество одновременно запущенных задач сверху

более конкретно -- есть вектор имён файлов и есть async метод по загрузке этих файлов. Нужно выполнить методы на тредпуле, при этом одновременно выполняться должно не больше чем N загрузок

5 ответов

8 просмотров

Можно еще вот так попробовать, чтоб не более чем N фьюч поллилось: https://docs.rs/futures/latest/futures/stream/trait.StreamExt.html#method.buffer_unordered

Так лимита ж нет на только лишь FuturesUnordered. Можно их скрестить и радоваться

Мерль- Автор вопроса

Если кому-то интересно, вот что получилось Использовал futures::Stream.buffer_unordered -> futures::BufferUnordered. Это позволяет получить квази-итератор футур. Футуры приезжают в порядке выполнения, так что в цикле можно пробежать по ним и обработать результаты. (это скачивалка книг из KyBook 3) https://github.com/ninedraft/ky-sync/blob/master/src/main.rs

Мерль- Автор вопроса
Мерль
Если кому-то интересно, вот что получилось Исполь...

кстати, буду благодарен, если накидаете в панамку за качество/идеоматиченость кода

Похожие вопросы

Обсуждают сегодня

я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
49
читать файл максимально быстро? странный вопрос))
zamtmn
53
How to create an OS in C? what to study?
Linus
18
Компания Elif ищет менеджера проектов, который будет заниматься поиском и ведением новых проектов. Прежде чем приступить к работе, вам нужно пройти наш недельный курс, где вы ...
Elif
5
Привет, кто может сделать юзербота с апи? Задачи: - создавать группы - создавать каналы - задавать для созданных каналов аватарку или эмоджи, имя группы - добавлять в группы...
Lencore
11
тоесть, указав return eax, сгенерируется никому ненужная инструкция mov eax,eax ?
Aiwan \ (•◡•) / _bot
24
@HemulGM Параметры у AddStream поменялись? Несостыковка какая-то
Катерина Свиридова
12
Подскажите, есть какие-то события создания/уничтожения у TFrame по типу TForm (OnCreate и OnClose/OnDestroy) ? Как отловить создание TFrame и "перед" уничтожением. На Tframe р...
Денис
8
а зачем этот вопрос для удаления из чата?
Mёdkinson Medvezhkin
63
а чем хуже?
Alexey Kulakov
10
Карта сайта