fearless concurrency macro

fearless.rs

macro_rules! fearless {
    ($t:ty) => {
        std::sync::Arc<std::sync::Mutex<$t>>
    };
    ($e:expr) => {
        std::sync::Arc::new(std::sync::Mutex::new($e))
    };
    (clone $e:expr) => {
        std::sync::Arc::clone(&$e)
    };
    (lock $e:expr) => {
        match $e.lock() {
            Ok(guard) => guard,
            Err(poisoned) => poisoned.into_inner(),
        }
    };
    (lock $e:expr, $err:expr) => {{
        match $e.lock() {
            Ok(guard) => guard,
            Err(_) => return $err,
        }
    }};
}

fn main() {
    #[derive(Debug)]
    struct X(fearless!(String));
    let x = X(fearless!("h".to_string()));
    println!("{:?}", x);
    let data = fearless!(5);
    let data_clone = fearless!(clone data);
    let mut locked_data = fearless!(lock data_clone, println!("Mutex is poisoned"));
    *locked_data += 1;
}