thorseraq · April 11, 2023 10:14
diff --git a/std-sync-mpsc-Receiver-multithread-share.rs b/std-sync-mpsc-Receiver-multithread-share.rs
 use std::sync::{mpsc, Arc, Mutex};
 use std::thread;
 use std::thread::sleep;

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

    for _ in 0..3 {
        let rx = rx.clone();
        thread::spawn(move || {
            while let Ok(data) = rx.lock().unwrap().recv() {
                println!("Received: {}", data);
            }
        });
    }

    for i in 0..10 {
        tx.send(format!("Data {}", i)).unwrap();
    }

    sleep(std::time::Duration::from_secs(10));
 }
	use std::sync::{mpsc, Arc, Mutex};
	use std::thread;
	use std::thread::sleep;

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

	for _ in 0..3 {
	let rx = rx.clone();
	thread::spawn(move \|\| {
	while let Ok(data) = rx.lock().unwrap().recv() {
	println!("Received: {}", data);
	}
	});
	}

	for i in 0..10 {
	tx.send(format!("Data {}", i)).unwrap();
	}

	sleep(std::time::Duration::from_secs(10));
	}
No results found