SPCMC(Single Producer, Multiple Consumer) pattern in Rust

spcmc.rs

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

type Closure = Box<dyn FnOnce() + Send + 'static>;
const ERR_LOCK: &str = "cant acquire resource";

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

    let rxtf = Arc::new(Mutex::new(rx));

    let rx1 = Arc::clone(&rxtf);
    let rx2 = Arc::clone(&rxtf);

    let handle = thread::spawn(move || loop {
        let data = match rx1.lock().expect(ERR_LOCK).recv() {
            Ok(data) => data,
            Err(_) => break,
        };
        data();
    });

    let handle2 = thread::spawn(move || loop {
        let data = match rx2.lock().expect(ERR_LOCK).recv() {
            Ok(data) => data,
            Err(_) => break,
        };
        data();
    });

    for i in 0..100000 {
        tx.send(Box::new(move || {
            println!("data:{}", i);
        }))
        .unwrap();
    }

    drop(tx);
    handle.join().expect("cant merge thread");
    handle2.join().expect("cant merge thread");
}