jthread 0.1.1

Deadlock-free Mutual Exclusion locks for Rust
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

use std::sync::Mutex;

use criterion::{criterion_group, criterion_main, Criterion};
use jthread::*;

pub fn single_lock_benchmark(c: &mut Criterion) {
    c.bench_function("Standard locking (single)", |b| {
        let m = Mutex::new(1);
        b.iter(|| {
            let mut d = m.lock().unwrap();
            *d += 1;
        });
    });

    c.bench_function("JThread locking (single)", |b| {
        let r = Region::new();
        let m = JMutex::new(1, r);
        b.iter(|| {
            let _ = sync!([m.clone()], |mut d| {
                *d += 1;
            });
        });
    });
}

pub fn double_lock_benchmark(c: &mut Criterion) {
    c.bench_function("Standard locking (double)", |b| {
        let m = Mutex::new(1);
        let n = Mutex::new(2);
        b.iter(|| {
            let mut d1 = m.lock().unwrap();
            let d2 = n.lock().unwrap();
            *d1 += *d2;
        });
    });

    c.bench_function("JThread locking (double)", |b| {
        let r1 = Region::new();
        let m = JMutex::new(1, r1);

        let r2 = Region::new();
        let n = JMutex::new(2, r2);

        b.iter(|| {
            let _ = sync!([m.clone()], |mut d1| {
                let _ = sync!([n.clone()], |d2| {
                    *d1 += *d2;
                });
            });
        });
    });
}

criterion_group!(benches, single_lock_benchmark, double_lock_benchmark);
criterion_main!(benches);