rust - 无法将 iter().fold(....) 转换为 Rayon 的 par_iter().fold(....)

Question

我正在尝试使用 Rayon启动一系列顶级线程以递归调用模拟函数。该代码在使用 channel 发送和接收时有效，因此它是多线程兼容的，但它无法使用 par_iter() 进行编译。

fn simulate(initial_board: &Board, player: Player, level: u32, start: bool) -> Option<AMove> {
...

    #[inline(always)]
    fn evaluate_move(previous: Option<AMove>, new_move: &AMove, new_score: i32, player: Player) -> AMove {
    ...
    }

... 

let accumlator = |previous: Option<AMove>, a_move: &Option<AMove>| if let Some(AMove { board: ref a_board, .. }) = *a_move {
        ...
    } else {
        previous
    };

    if start && !winning {
        the_move = moves.par_iter().fold(the_move, accumlator);
    } else {
        the_move = moves.iter().fold(the_move, accumlator);
    }

    the_move
}

我在 par_iter() 行遇到编译器错误，我不知道如何解决这些错误。

error[E0277]: the trait bound `std::option::Option<AMove>: std::ops::Fn<()>` is not satisfied
   --> src/main.rs:271:37    
    |
271 |         the_move = moves.par_iter().fold(the_move, accumlator);
    |                                     ^^^^ the trait `std::ops::Fn<()>` is not implemented for `std::option::Option<AMove>`

error[E0277]: the trait bound `std::option::Option<AMove>: std::ops::FnOnce<()>` is not satisfied
   --> src/main.rs:271:37
    |
271 |         the_move = moves.par_iter().fold(the_move, accumlator);
    |                                     ^^^^ the trait `std::ops::FnOnce<()>` is not implemented for `std::option::Option<AMove>`

error[E0308]: mismatched types
   --> src/main.rs:271:20
    |
271 |         the_move = moves.par_iter().fold(the_move, accumlator);
    |                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^        expected enum `std::option::Option`, found struct `rayon::iter::Fold`
    |
    = note: expected type `std::option::Option<_>`
               found type `rayon::iter::Fold<rayon::slice::Iter<'_, std::option::Option<AMove>>, std::option::Option<_>, [closure@src/main.rs:224:22: 240:6 winning:_, level:_, player:_]>`

Answer 1

Rayon 的 fold 需要一个生成标识元素而不是单个基本元素的函数。在您的情况下，如果 AMove 是 Copy + Send + Sync，只需执行 moves.par_iter().fold(|| the_move, accumlator)应该足够好了。

如果AMove不是Copy，使用|| the_move.clone().

Rayon 可能想要生成多个标识元素以并行处理不同的 block ，并且只在最后合并结果，这就是为什么它需要能够根据需要生成尽可能多的标识元素。

检查 fold 的 signature .此外，如果您的累加器返回与标识元素相同的类型，您可能希望改用 reduce(有关差异，请参阅链接文档)。

另一个问题是您不能按照您尝试的方式使用递归闭包(Rust 不能那样做)。请为您的累加器使用命名函数。