الخيوط وSend وSync والحالة المشتركة

use std::sync::{Arc, Mutex};
use std::thread;
fn main() {
    let count = Arc::new(Mutex::new(0u32));
    let mut workers = Vec::new();
    for _ in 0..2 {
        let count = Arc::clone(&count);
        workers.push(thread::spawn(move || {
            for _ in 0..100 { *count.lock().unwrap() += 1; }
        }));
    }
    for worker in workers { worker.join().unwrap(); }
    println!("{}", *count.lock().unwrap());
}

200

يسهم كل عامل بمئة زيادة محمية، ويُضمّان قبل القراءة النهائية تحت الحراسة.

use std::sync::mpsc;
use std::thread;
fn main() {
    let (sender, receiver) = mpsc::channel();
    let mut workers = Vec::new();
    for name in ["south", "north"] {
        let sender = sender.clone();
        workers.push(thread::spawn(move || sender.send(String::from(name)).unwrap()));
    }
    drop(sender);
    let mut messages: Vec<String> = receiver.into_iter().collect();
    for worker in workers { worker.join().unwrap(); }
    messages.sort();
    println!("{:?}", messages);
}

["north", "south"]

تملك القناة السلاسل المنقولة، ويزيل الفرز اعتماد الإخراج على ترتيب الوصول.