dark-std 0.2.16

dark-std is an Implementation of asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang
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
83
84
85

#![feature(test)]
extern crate test;

use dark_std::sync::SyncVec;
use std::sync::RwLock;

//test bench_rw_vec        ... bench:           4 ns/iter (+/- 0)
#[bench]
fn bench_rw_vec(b: &mut test::Bencher) {
    let rw = RwLock::new(vec![1]);
    b.iter(|| {
        let _a = rw.read().unwrap().get(0);
    });
}

//test bench_sync_vec      ... bench:           0 ns/iter (+/- 0)
#[bench]
fn bench_sync_vec(b: &mut test::Bencher) {
    let rw = SyncVec::new();
    rw.push(1);
    assert_eq!(rw.len(), 1);
    let mut i = 0;
    b.iter(|| {
        let _a = rw.get(i);
        i += 1;
    });
}

//test bench_sync_vec_push ... bench:           17 ns/iter (+/- 2)
#[bench]
fn bench_vec_push(b: &mut test::Bencher) {
    let rw = std::sync::Mutex::new(vec![1]);
    let mut i = 0;
    b.iter(|| {
        rw.lock().unwrap().push(i);
        i += 1;
    });
}

//test bench_sync_vec_push ... bench:           17 ns/iter (+/- 7)
#[bench]
fn bench_sync_vec_push(b: &mut test::Bencher) {
    let rw = SyncVec::new();
    let mut i = 0;
    b.iter(|| {
        rw.push(i);
        i += 1;
    });
}

//test bench_sync_vec_push ... bench:           15 ns/iter (+/- 1)
#[bench]
fn bench_queue_push(b: &mut test::Bencher) {
    let rw = crossbeam::queue::ArrayQueue::new(40000_0000);
    let mut i = 0;
    b.iter(|| {
        let _r = rw.push(i);
        i += 1;
        if i == 40000_0000 - 2 {
            return;
        }
    });
}

// test bench_queue2_push   ... bench:          27 ns/iter (+/- 2)
#[bench]
fn bench_queue2_push(b: &mut test::Bencher) {
    let rw = crossbeam::queue::SegQueue::new();
    let mut i = 0;
    b.iter(|| {
        let _r = rw.push(i);
        i += 1;
    });
}

// test bench_queue_push    ... bench:          13 ns/iter (+/- 1)
#[bench]
fn bench_channel_send(b: &mut test::Bencher) {
    let (send, rev) = crossbeam::channel::unbounded();
    let mut i = 0;
    b.iter(|| {
        let _r = send.send(i).unwrap();
        i += 1;
    });
}