linked 1.0.9

Create families of linked objects that can collaborate across threads while being internally single-threaded
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! Basic operations on linked objects.

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

use linked::Object;

#[test]
fn linked_objects_smoke_test() {
    #[linked::object]
    struct Thing {
        local_value: usize,
        global_value: Arc<Mutex<String>>,
    }

    impl Thing {
        fn new(local_value: usize, global_value: String) -> Self {
            let global_value = Arc::new(Mutex::new(global_value));

            linked::new!(Self {
                local_value,
                global_value: Arc::clone(&global_value),
            })
        }

        fn set_global_value(&self, value: &str) {
            let mut global_value = self.global_value.lock().unwrap();
            *global_value = value.to_string();
        }

        fn get_global_value(&self) -> String {
            let global_value = self.global_value.lock().unwrap();
            global_value.clone()
        }

        fn get_local_value(&self) -> usize {
            self.local_value
        }

        fn set_local_value(&mut self, value: usize) {
            self.local_value = value;
        }
    }

    let mut linked_object = Thing::new(42, "hello".to_string());

    assert_eq!(linked_object.get_local_value(), 42);
    assert_eq!(linked_object.get_global_value(), "hello");

    let clone = linked_object.clone();

    linked_object.set_global_value("world");
    linked_object.set_local_value(43);

    assert_eq!(linked_object.get_local_value(), 43);
    assert_eq!(linked_object.get_global_value(), "world");

    assert_eq!(clone.get_local_value(), 42);
    assert_eq!(clone.get_global_value(), "world");

    let handle = linked_object.family();

    thread::spawn(move || {
        let mut linked_object: Thing = handle.into();

        assert_eq!(linked_object.get_local_value(), 42);
        assert_eq!(linked_object.get_global_value(), "world");

        linked_object.set_global_value("paradise");
        linked_object.set_local_value(45);
    })
    .join()
    .unwrap();

    assert_eq!(linked_object.get_local_value(), 43);
    assert_eq!(linked_object.get_global_value(), "paradise");

    assert_eq!(clone.get_local_value(), 42);
    assert_eq!(clone.get_global_value(), "paradise");
}