Rust嵌套循环结合Rayon for_each_with与mpsc Sender编译报错如何解决

错误根因 #

1. std::sync::mpsc::Sender仅实现了Send trait，未实现Sync trait：你传递&sender共享引用到并行迭代时，跨线程共享引用要求目标类型实现Sync，因此触发第一个编译错误。
2. 直接转移sender所有权到for_each_with的话，外层循环是FnMut闭包，每次迭代都需要访问sender，第一次迭代就把所有权移走后，后续迭代无法再访问该变量，因此触发移动错误。

修复方案 #

每次外层循环迭代时，先克隆一份独立的sender副本，再将该副本传入内层并行迭代的for_each_with即可。Sender的克隆成本极低，仅为原子引用计数加1，是多生产者通道的标准使用方式。

修复后的完整代码：

use std::sync::mpsc::channel;
use rayon::prelude::*;

fn main(){
    let (sender, receiver) = channel();

    (0..5).for_each(|i|{
        // 克隆独立的sender副本供当前外层迭代的内层并行循环使用
        let sender_clone = sender.clone();
        (0..5).into_par_iter().for_each_with(sender_clone, |sender, j|{
            sender.send(i + j).unwrap();   
        });
    });

    // 销毁原始sender，关闭通道的发送端，否则receiver会永久阻塞等待新消息
    drop(sender);

    // 接收所有结果验证正确性
    let mut results: Vec<i32> = receiver.iter().collect();
    results.sort_unstable();
    println!("计算结果：{:?}", results);
}

方案说明 #

• 每次外层迭代生成的克隆sender所有权直接转移给内层for_each_with，不会消耗原始sender，也不存在跨线程共享引用的问题，满足Send要求即可正常编译运行。
• 所有克隆的sender和原始sender都指向同一个通道，发送的消息都会被同一个receiver接收。
• 最后必须主动drop原始sender，否则通道会一直处于打开状态，receiver.iter()会无限阻塞等待新消息。

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