複数のスレッドに読み込み専用の行列（Vec <Vec<f64>>）を渡す

Question

私は錆に慣れています。私は借りるというコンセプトに苦しんでいます。

Vec<Vec<f64>>行列をロードして、それを並列処理したいとします。しかし、このコードをコンパイルしようとするとerror: capture of moved value: `matrix` [E0382]がlet _ =行になります。

この行列はスレッドのためだけに読み込まれるはずですが、変更されません。どのように私はそれを読み取り専用で渡すことができ、 "移動された値"のエラーをなくすことができますか？

fn process(matrix: &Vec<Vec<f64>>) { 
    // do nothing for now 
} 

fn test() { 
    let filename = "matrix.tsv"; 
    // loads matrix into a Vec<Vec<f64>> 
    let mut matrix = load_matrix(filename); 

    // Determine number of cpus 
    let ncpus = num_cpus::get(); 
    println!("Number of cpus on this machine: {}", ncpus); 
    for i in 0..ncpus { 
     // In the next line the "error: capture of moved value: matrix" happens 
     let _ = thread::spawn(move || { 
      println!("Thread number: {}", i); 
      process(&matrix); 
     }); 
    } 
    let d = Duration::from_millis(1000 * 1000); 
    thread::sleep(d); 
} 

Answer 1

（ポインタ）をカウントアトミック参照を表しArcに共有されるオブジェクトをラップ。各スレッドについて、このポインタを複製し、クローンの所有権をスレッドに渡します。ラップされたオブジェクトは、何も使用されなくなると割り当てが解除されます。

fn process(matrix: &Vec<Vec<f64>>) { 
    // do nothing for now 
} 

fn test() { 
    use std::sync::Arc; 
    let filename = "matrix.tsv"; 
    // loads matrix into a Vec<Vec<f64>> 
    let mut matrix = Arc::new(load_matrix(filename)); 

    // Determine number of cpus 
    let ncpus = num_cpus::get(); 
    println!("Number of cpus on this machine: {}", ncpus); 
    for i in 0..ncpus { 
     let matrix = matrix.clone(); 
     let _ = thread::spawn(move || { 
      println!("Thread number: {}", i); 
      process(&matrix); 
     }); 
    } 
    let d = Duration::from_millis(1000 * 1000); 
    thread::sleep(d); 
}