thread examples

thread-example-1.rs

use std::thread;

fn main() {
    let mut list = Vec::new();

    let my_thread = thread::spawn(move || {
        add_elements_to(&mut list);
        list
    });

    let list = my_thread.join().unwrap();
    println!("{:?}", &list);
}

fn add_elements_to(list: &mut Vec<u32>) {
    list.append(&mut vec![1, 2, 3]);
}

thread-example-2.rs

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

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

    spawn_workers(tx);

    let result: u32 = rx.iter().sum();
    println!("Result: {}", result);
}

fn spawn_workers(tx: mpsc::Sender<u32>) {
    for i in 1..=10 {
        let tx_inner = tx.clone();
        thread::spawn(move || {
            tx_inner.send(i)
        });
    }
}