generational-box 0.7.6

A box backed by a generational runtime
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

// Regression test for https://github.com/DioxusLabs/dioxus/issues/2636

use std::time::Duration;

use generational_box::{AnyStorage, GenerationalBox, SyncStorage};

#[test]
fn race_condition_regression() {
    for _ in 0..100 {
        let handle = {
            let owner = SyncStorage::owner();
            let key = owner.insert(1u64);
            let handle = std::thread::spawn(move || reader(key));

            std::thread::sleep(Duration::from_millis(10));
            handle
            // owner is dropped now
        };
        // owner is *recycled*
        let owner = SyncStorage::owner();
        let _key = owner.insert(2u64);
        let _ = handle.join();
    }
}

fn reader(key: GenerationalBox<u64, SyncStorage>) {
    for _ in 0..1000000 {
        match key.try_read() {
            Ok(value) => {
                if *value == 2 {
                    panic!("Read a new value with the old generation");
                } else {
                    // fine
                }
            }
            Err(err) => {
                eprintln!("bailing out - {err:?}");
                break;
            }
        }
    }
}