таски и выполнять их пачками. То есть, например, нужно сделать 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();
}
конечно он не работает, ты же ждёшь какой-то период, а не пока таски выполнятся
if i% 1000 == 0 { for join_handle in tasks.drain(..) { join_handle.await.unwrap() } }
Кстати, использование мутабельной ссылки на Arc выглядит подозрительно. Или внутри task используются Arc::get_mut() или Arc::make_mut()?
Обсуждают сегодня