Rust：如何在循环中执行大量并发？

Question

假设我有这样的计算：

async fn sum_2(x: &f64) -> f64 {
   x + 2
}

fn main() {
   let mut x = vec![
      vec![1.0, 2.0, 3.0],
      vec![2.0, 3.0, 4.0],
   ];

   for i in 0..2 {
      for j in 0..3 {
         x[i][j] = sum_2(x[i][j]).await;
      }
   }
}

同时执行此操作的正确/更好方法是什么？ 我知道join!()，当呼叫已知时，这非常好。 我也知道thread::spawn()，但我不知道这是否是实现这一目标的正确工具，也不知道如何实现。 Rust 中难道没有像线程池这样的东西，我可以将所有函数调用发送到然后执行吗？谢谢！

Answer 1

您似乎在寻找futures::future::join_all。

来自官方的例子：

use futures::future::join_all;
async fn foo(i: u32) -> u32 { i }
let futures = vec![foo(1), foo(2), foo(3)];
assert_eq!(join_all(futures).await, [1, 2, 3]);