storage-map 0.3.0

Concurrent append-only map storage
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

use std::{
    collections::hash_map::{HashMap, RandomState},
    sync::Arc,
    thread, time,
};

#[test]
fn fill_ten() {
    type Map = HashMap<u8, String, RandomState>;
    let s = RandomState::new();
    let map = storage_map::StorageMap::<parking_lot::RawRwLock, Map>::with_hasher(s);
    let arc = Arc::new(map);
    let join_handles = (0..10000usize)
        .map(|i| {
            let arc = Arc::clone(&arc);
            let key = (i % 10) as u8;
            thread::spawn(move || {
                arc.get_or_create_with(&key, || {
                    thread::sleep(time::Duration::new(0, 100));
                    format!("{}", i)
                });
            })
        })
        .collect::<Vec<_>>();
    for handle in join_handles {
        let _ = handle.join();
    }
}

#[test]
fn whole_write() {
    type Map = HashMap<u8, String, RandomState>;
    let map =
        storage_map::StorageMap::<parking_lot::RawRwLock, Map>::with_hasher(RandomState::new());
    map.get_or_create_with(&3, || "three".to_owned());
    map.get_or_create_with(&5, || "five".to_owned());
    let mut guard = map.whole_write();
    for (_key, _value) in guard.drain() {
        //nothing
    }
}