move クロージャ — スレッドに所有権を渡すのサンプルコード — Rust

1最小の move — Vec を預けて合計

move を付けて Vec の所有権をスレッドに渡す最小の例です。スレッドは main より長く生きるかもしれないので、借用ではなく所有権ごと渡すのが原則になります。move を消すとコンパイルエラーになるので、エラーメッセージもぜひ一度見てみてください。

Rust

use std::thread;

fn main() {
    let numbers = vec![3, 1, 4, 1, 5, 9, 2, 6];

    // move がないと「numbers が先に消えるかも」とコンパイルエラーになる
    let handle = thread::spawn(move || numbers.iter().sum::<i32>());

    let total = handle.join().unwrap();
    println!("合計 = {}", total);
}

2clone して渡す — 元の変数も使う

move で渡したあとも元の変数を使いたいときは、clone した複製をスレッドに渡します。message は手元に残り、for_thread だけが move されるという切り分けです。設定値やファイルパスのような小さなデータなら、実務でもまず clone で済ませるのが手軽です。

Rust

use std::thread;

fn main() {
    let message = String::from("締め切りは金曜日");
    let for_thread = message.clone(); // 渡す前に複製しておく

    let handle = thread::spawn(move || format!("[スレッド] 受信: {}", for_thread));

    println!("[メイン] 手元にも残っている: {}", message);
    println!("{}", handle.join().unwrap());
}

3ループで分配 — 各スレッドに専用データ

ループの各回で取り出した chunk が、その回に作ったスレッドへ move される様子を示します。データを分割して各スレッドに専用の持ち分を配るのは、並列集計の基本パターンです。join を Vec の順に回しているので、結果の表示順は毎回同じになります。

Rust

use std::thread;

fn main() {
    let chunks = vec![vec![1, 2, 3], vec![40, 50], vec![600]];
    let mut handles = Vec::new();

    for chunk in chunks {
        // この回の chunk の所有権がそのスレッド専用になる
        handles.push(thread::spawn(move || chunk.iter().sum::<i32>()));
    }

    let mut total = 0;
    for (i, handle) in handles.into_iter().enumerate() {
        let sub = handle.join().unwrap();
        println!("チャンク{} の小計 = {}", i + 1, sub);
        total += sub;
    }
    println!("総合計 = {}", total);
}

4構造体ごと move — 返り値で返してもらう

String や Vec を含む構造体も、move で丸ごとスレッドに預けられます。返り値のタプルで「名前と結果」を返してもらえば、必要なものだけが所有権ごと戻ってくる形になります。ジョブを構造体にまとめてワーカーに渡す、実務でよくある形の縮小版です。

Rust

use std::thread;

struct Task {
    name: String,
    values: Vec<u32>,
}

fn main() {
    let task = Task { name: String::from("売上集計"), values: vec![120, 80, 200] };

    let handle = thread::spawn(move || {
        let sum: u32 = task.values.iter().sum();
        (task.name, sum) // 必要なものは返り値で返してもらう
    });

    let (name, sum) = handle.join().unwrap();
    println!("{}: 合計 {}", name, sum);
}

5ファイル別ワーカーでエラー行を並列集計

ファイル名と中身のペアを1スレッドずつに move して、エラー行数を並列に数える例です。各スレッドが自分のデータだけを所有するので、ロックも共有も要りません。「分けて配って join で集める」は、共有状態なしで済むいちばん安全な並列化です。

Rust

use std::thread;

fn main() {
    let files = vec![
        (String::from("a.log"), String::from("ok\nerror: disk\nok\n")),
        (String::from("b.log"), String::from("error: net\nerror: auth\n")),
    ];
    let mut handles = Vec::new();
    for (name, content) in files {
        // name と content の所有権が move で各スレッドへ移る
        handles.push(thread::spawn(move || (name, content.lines().filter(|l| l.starts_with("error")).count())));
    }
    let mut total = 0;
    for handle in handles {
        let (name, errors) = handle.join().unwrap();
        println!("{}: エラー {} 件", name, errors);
        total += errors;
    }
    println!("合計エラー {} 件", total);
}

サンプルコードで身につける: move クロージャ — スレッドに所有権を渡す

1最小の move — Vec を預けて合計

2clone して渡す — 元の変数も使う

3ループで分配 — 各スレッドに専用データ

4構造体ごと move — 返り値で返してもらう

5ファイル別ワーカーでエラー行を並列集計