サンプルコードで身につける: チャネル — スレッド間でデータを送る

use std::sync::mpsc;
use std::thread;

fn main() {
    let (tx, rx) = mpsc::channel();

    let handle = thread::spawn(move || {
        tx.send(String::from("計算が終わりました")).unwrap();
    });

    let message = rx.recv().unwrap(); // 届くまでここで待つ
    println!("受信: {}", message);
    handle.join().unwrap();
}

use std::sync::mpsc;
use std::thread;

fn main() {
    let (tx, rx) = mpsc::channel();

    let handle = thread::spawn(move || {
        for i in 1..=5 {
            tx.send(i * i).unwrap();
        }
    }); // スレッド終了で tx が drop され、下のループも終わる

    for received in rx {
        println!("受信: {}", received); // 送信元が1本なら届く順=送った順
    }
    handle.join().unwrap();
}

use std::sync::mpsc;
use std::thread;

fn main() {
    let (tx, rx) = mpsc::channel();
    let mut handles = Vec::new();
    for worker in 0..3 {
        let tx = tx.clone(); // 送信機は clone して各スレッドに配れる
        handles.push(thread::spawn(move || {
            for i in 1..=10 {
                tx.send(worker * 100 + i).unwrap();
            }
        }));
    }
    drop(tx); // 元の tx も手放さないと受信が終わらない

    let total: i32 = rx.iter().sum(); // 到着順に依存しない集計にする
    println!("3スレッドから受け取った30個の合計 = {}", total);
    for handle in handles { handle.join().unwrap(); }
}

use std::{sync::mpsc, thread};

fn main() {
    let (job_tx, job_rx) = mpsc::channel();
    let (result_tx, result_rx) = mpsc::channel();

    let worker = thread::spawn(move || {
        for n in job_rx {
            result_tx.send((n, n * n)).unwrap(); // 結果は別チャネルで返す
        }
    }); // job_rx が閉じたら worker も終わり result_tx が drop される

    for n in vec![3u64, 7, 10] { job_tx.send(n).unwrap(); }
    drop(job_tx); // 「仕事はもう無い」と伝える

    for (n, squared) in result_rx {
        println!("{} の2乗 = {}", n, squared);
    }
    worker.join().unwrap();
}

use std::{sync::mpsc, thread};

fn main() {
    let files = vec![
        (String::from("api.log"), String::from("ok\nerror\nok\nerror\n")),
        (String::from("db.log"), String::from("error\nok\n")),
    ];
    let (tx, rx) = mpsc::channel();
    let handles: Vec<_> = files.into_iter().map(|(name, content)| {
        let tx = tx.clone();
        thread::spawn(move || tx.send((name, content.lines().filter(|l| l.contains("error")).count())).unwrap())
    }).collect();
    drop(tx); // 手元の tx を手放すと、全ワーカー終了後に受信が終わる
    let mut results: Vec<_> = rx.iter().collect();
    results.sort(); // 到着順は実行ごとに変わりうるので名前順に揃える
    for (name, errors) in &results { println!("{}: エラー {} 件", name, errors); }
    for handle in handles { handle.join().unwrap(); }
}