atum 0.1.0

Lock-free bidirectional Atom Table, optimized for multi-threaded workloads
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

use atum::prelude::*;

use std::sync::Arc;
use std::thread;

#[test]
fn threaded_stress() {
    let table = Arc::new(AtomTable::new());

    let handles = (0..8)
        .map(|_| {
            let table = table.clone();
            thread::spawn(move || {
                for i in 0..100_000 {
                    let s = format!("key{}", i % 100);
                    let id = table.intern(&s);
                    assert_eq!(table.lookup_ref(id).as_ref(), s);
                    assert_eq!(table.intern(&s), id);
                }
            })
        })
        .collect::<Vec<_>>();

    for h in handles {
        h.join().unwrap();
    }
}