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

таски и выполнять их пачками. То есть, например, нужно сделать 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 ответов

19 просмотров

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

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

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

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

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

'frakturBold' => ['𝖆', '𝖇', '𝖈', '𝖉', '𝖊', '𝖋', '𝖌', '𝖍', '𝖎', '𝖏', '𝖐', '𝖑', '𝖒', '𝖓', '𝖔', '𝖕', '𝖖', '𝖗', '𝖘', '𝖙', '𝖚', '𝖛', '𝖜', '𝖝', '𝖞', '𝖟', '𝕬', '𝕭', '𝕮', '𝕯'...
Roma
4
Подскажите пж Юзер отправляет текст с картинкой, как получить айди этой картинки? Ну или саму картинку, мне она потом все равно в виде буфера нужна
Ilya Taeronn
6
а шо с ютубом совсем пиздец?
Андрей
4
Гутен морген А кто-нибудь уже изучал вопрос как делать тапалки? Часть с ботом+сам мини апп как делать понимаю, вопрос в интеграции с блокчейном. Его тоже базу уже немного пони...
𝖒 𝖊 𝖙 𝖆 𝖒 𝖔 𝖉 𝖊 𝖗 𝖓 💋❤️🖤❤️🖤💋 龙
10
Сonst magicTgHTML = (text, entities) => { let processedText = text; let offsetShift = 0; entities.forEach(entity => { const { offset, length, type, url, ...
Андрей
1
Всем привет, а может кто-нибудь подсказать Если зайти в BotFather и справа нажать на три точки, то там есть кнопка "отправить свой телефон" Можно ли это как-то реализовать в с...
Artem Stormageddon
4
а что делать если тебя убивают на картах?
Yarik yarik kyda ti lezesh
43
if (user?.choseType === 'oneDay') { await ctx.reply( 'Добро пожаловать в команду «Магнита»! Правда, на один день ☺️ ', ); await ctx.s...
Kokni
1
Товарищи, здравствуйте Подскажите, пожалуйста, по поводу deeplink Есть ли какая-то возможность передать не такой t.me/your_bot?start=XXXX А что-то такое? t.me/your_bot?new=XX...
Artem Stormageddon
5
у вас клиент тг на мобиле не висит?
meow *
3
Карта сайта