Rust中Rayon并行循环累加成功次数时编译错误排查

错误原因 #

你遇到的编译错误根源在于：Rayon的并行迭代器要求闭包是Fn类型（不可变捕获外部变量），而直接修改won_games属于可变捕获（FnMut闭包）。在并行场景下，多个线程同时修改同一个共享变量会引发数据竞争，Rust的内存安全机制直接禁止了这种不安全操作。

正确实现方式 #

Rayon提供了fold和reduce方法来安全处理并行统计需求：

• fold：为每个线程初始化局部计数器，在各线程内独立统计获胜次数，完全避免共享可变状态。
• reduce：将所有线程的局部统计结果合并成最终总获胜次数，由Rayon安全处理线程间的合并逻辑。

同时注意你代码里的笔误：change分支应该调用run_game_change（而非和else分支一样用run_game_no_change），否则逻辑不符合蒙提霍尔问题的设定。

修正后的代码如下：

use rayon::prelude::*;

fn gameshow(num_doors: usize, num_runs: usize, change: bool) -> usize {
    let runs: Vec<Vec<bool>> = vec![stagehand(num_doors); num_runs];

    runs.into_par_iter()
        .fold(|| 0, |local_count, game| {
            let winner = if change {
                run_game_change(game)
            } else {
                run_game_no_change(game)
            };
            if winner { local_count + 1 } else { local_count }
        })
        .reduce(|| 0, |a, b| a + b)
}

// 以下为假设已实现的辅助函数
fn stagehand(num_doors: usize) -> Vec<bool> {
    let mut doors = vec![false; num_doors];
    doors[rand::random::<usize>() % num_doors] = true;
    doors
}

fn run_game_no_change(doors: Vec<bool>) -> bool {
    let choice = rand::random::<usize>() % doors.len();
    doors[choice]
}

fn run_game_change(doors: Vec<bool>) -> bool {
    let choice = rand::random::<usize>() % doors.len();
    // 蒙提霍尔换门逻辑：初始选中中奖门则换门失败，否则换门必中
    !doors[choice]
}

关键说明 #

• fold(|| 0, ...)：每个线程从0开始统计局部获胜次数，闭包仅操作局部变量，无共享状态风险。
• reduce(|| 0, ...)：将所有线程的局部计数相加，Rayon自动处理线程安全合并，无需手动同步。
• 简化了原代码的分支结构，直接在fold闭包内根据change变量选择对应游戏逻辑，代码更简洁。

内容的提问来源于stack exchange，提问作者Penultimate Panacea