如何使用 tokio、async-std 并行化几分钟

Question

我想使用 tokio 或 async-std 在多线程中执行以下处理。我已经阅读了关于 tokio 和 async-std 的教程，但我认为没有提到并行化 for。在此过程中，所有线程都引用相同的数组索引。此外，所有线程将访问同一数组的不同位置。

let input_array: Array2<f32>;  
let output_array: Array2<f32>;
for i in 0..roop_num {
  let res = do_some_func(&input_array, idx);
  output_array.slice_mut(s![idx, ...]) .assign(&res);
}

我想把上面代码的for部分改为并行处理

Answer 1

Tokio 或 async-std 处理并发性，而不是并行性。如果您需要数据并行性，那么 rayon is a library to choose. If you are using an Iterator trait, then chunks() method is good. For more imperative approach you can use

如何使用 tokio、async-std 并行化几分钟

How to parallelize for minutes using tokio, async-std

rust

tokio

rust-async-std