peace 0.0.15

zero stress automation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

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

#[derive(Debug)]
struct Data {
    value: u32,
}

fn main() -> thread::Result<()> {
    let data = Data { value: 0 };
    let arc_mutex = Arc::new(Mutex::new(data));
    let arc_mutex_0 = arc_mutex.clone();
    let arc_mutex_1 = arc_mutex.clone();

    let work_0 = move || {
        (0..50000).for_each(|_| {
            if let Ok(mut data) = arc_mutex_0.lock() {
                data.value += 1;
            }
        });
    };
    let work_1 = move || {
        (0..50000).for_each(|_| {
            if let Ok(mut data) = arc_mutex_1.lock() {
                data.value += 1;
            }
        })
    };

    let thread_0 = thread::spawn(work_0);
    let thread_1 = thread::spawn(work_1);

    thread_0.join()?;
    thread_1.join()?;

    if let Ok(Ok(data)) = Arc::try_unwrap(arc_mutex).map(Mutex::into_inner) {
        println!("value: {}", data.value);
    }

    Ok(())
}