lightning-containers 0.2.0

A set of lock-free data structures
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
81
82

use bustle::{Mix, Workload};

mod arc_mutex_std;
mod arc_rwlock_std;
mod chashmap;
mod lfmap;

fn main() {
    tracing_subscriber::fmt::init();
    // Workload::new(8, Mix::insert_heavy()).run::<lfmap::TestTable>();
    // Workload::new(16, Mix::uniform()).run::<lfmap::TestTable>();
    // Workload::new(126, Mix::read_heavy()).run::<lfmap::TestTable>();
    // Workload::new(1, Mix::uniform()).run::<lfmap::TestTable>();
    test_lfmap();
    test_chashmap();
    // test_rwlock_std();
    // test_mutex_std();
}

fn test_lfmap() {
    println!("Testing lock-free map");
    println!("Insert heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::insert_heavy()).run::<lfmap::TestTable>();
    }
    println!("Read heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::read_heavy()).run::<lfmap::TestTable>();
    }
    println!("Uniform");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::uniform()).run::<lfmap::TestTable>();
    }
}

fn test_rwlock_std() {
    println!("Testing rwlock std map");
    println!("Insert heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::insert_heavy()).run::<arc_rwlock_std::Table<u64>>();
    }
    println!("Read heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::read_heavy()).run::<arc_rwlock_std::Table<u64>>();
    }
    println!("Uniform");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::uniform()).run::<arc_rwlock_std::Table<u64>>();
    }
}

fn test_mutex_std() {
    println!("Testing mutex std map");
    println!("Insert heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::insert_heavy()).run::<arc_mutex_std::Table<u64>>();
    }
    println!("Read heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::read_heavy()).run::<arc_mutex_std::Table<u64>>();
    }
    println!("Uniform");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::uniform()).run::<arc_mutex_std::Table<u64>>();
    }
}

fn test_chashmap() {
    println!("Testing CHashmap");
    println!("Insert heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::insert_heavy()).run::<chashmap::Table<u64>>();
    }
    println!("Read heavy");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::read_heavy()).run::<chashmap::Table<u64>>();
    }
    println!("Uniform");
    for n in 1..=num_cpus::get() {
        Workload::new(n, Mix::uniform()).run::<chashmap::Table<u64>>();
    }
}