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

таски и выполнять их пачками. То есть, например, нужно сделать 120к тасок, запускаем первые 1к, подождём пока выполнятся, потом вторые 1к. Этот код кладёт мою машину из-за большого кол-ва тасок.
let mut tasks = vec![];
let sec = Duration::from_millis(500);
let mut i = 0;
for line in book.lines.into_iter() {
i += 1;
if i % 1000 == 0 { // Костыль, который не работает)
sleep(sec).await;
}
let mut b = Arc::clone(&new_book_mutex);
tasks.push(tokio::spawn(async move {
task(
&line,
&mut b,
).await
}))
}
for task in tasks {
task.await.ok();
}

3 ответов

30 просмотров

конечно он не работает, ты же ждёшь какой-то период, а не пока таски выполнятся

if i% 1000 == 0 { for join_handle in tasks.drain(..) { join_handle.await.unwrap() } }

Кстати, использование мутабельной ссылки на Arc выглядит подозрительно. Или внутри task используются Arc::get_mut() или Arc::make_mut()?

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

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

Всем привет. Ребята, подскажите, пожалуйста. у ботов есть ограничение на отправку сообщений - 30 сообщений в секунду, эти ограничения накладываются на все сообщения? или на со...
Artem Stormageddon
4
Блин, ребята, сори за тупые вопросы. А можно ли как-то открыть вебапку по нажатию на кнопку в меню(которое появляется слева, команды)?
Artem Stormageddon
3
Ребята, всем привет. Подскажите, пожалуйста, можно ли как-то через бота понять, что этого бота добавили в группу\канал и выдали ему права администратора?
Artem Stormageddon
9
Привет всем! Почему этот код не срабатывает при добавлении или удалении пользователя из чата? bot.on('chat_member', async (ctx) => { console.log(ctx); }) bot.launch({allo...
Alexander
7
Всем привет. Не понимаю, в чём тут шутка юмора. Убирается только разрешение на send_messages. А send_media_messages остаётся. Как сделать, чтобы оба убирались? await b...
Alexander
2
Есть тут кто занимается разработкой серваков майна? Или знакомые
meow *
3
'frakturBold' => ['𝖆', '𝖇', '𝖈', '𝖉', '𝖊', '𝖋', '𝖌', '𝖍', '𝖎', '𝖏', '𝖐', '𝖑', '𝖒', '𝖓', '𝖔', '𝖕', '𝖖', '𝖗', '𝖘', '𝖙', '𝖚', '𝖛', '𝖜', '𝖝', '𝖞', '𝖟', '𝕬', '𝕭', '𝕮', '𝕯'...
Roma
4
Есть ли лимиты на кол-во вебхук по домену? Стоит в данный момент 900+ ботов и бывает бот перестает отвечать (не приходят вебхуки) 🐒 Помогает только перезапуск
ᅠ [ Кому не ответил, дублируйте ]
11
а что делать если тебя убивают на картах?
Yarik yarik kyda ti lezesh
43
Товарищи, здравствуйте Подскажите, пожалуйста, может кто-нибудь сталкивался с такой задачей Через вебапку можно сканировать qr-код, а есть ли возможность считывать nfc?
Artem Stormageddon
8
Карта сайта