swait 0.1.2

A Simple Utility for Blocking on Futures
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

use criterion::{black_box, criterion_group, criterion_main, Criterion};
use std::thread;
use swait::FutureExt;

async fn simple_async() -> isize {
    777
}

// Benchmark for a simple future that immediately completes.
fn bench_swait_basic(c: &mut Criterion) {
    c.bench_function("swait_basic", |b| {
        b.iter(|| {
            let result = black_box(simple_async()).swait();
            assert_eq!(result, 777);
        })
    });
}

// Benchmark for a simple future that immediately completes.
fn bench_pollster_basic(c: &mut Criterion) {
    use pollster::FutureExt;
    c.bench_function("pollster_basic", |b| {
        b.iter(|| {
            let result = black_box(simple_async()).block_on();
            assert_eq!(result, 777);
        })
    });
}

// Benchmark for receiving a message from another thread using kanal.
fn bench_message_passing_kanal_swait(c: &mut Criterion) {
    c.bench_function("message_passing_kanal_swait", |b| {
        let (sender, receiver) = kanal::bounded_async(0);

        let handle = thread::spawn(move || loop {
            if sender.send(777).swait().is_err() {
                break;
            }
        });
        b.iter(|| {
            // Receiving the message
            let received = receiver.recv().swait().unwrap();
            assert_eq!(received, 777);
        });
        drop(receiver);
        _ = handle.join();
    });
}

// Benchmark for receiving a message from another thread using kanal.
fn bench_message_passing_kanal_sync_api(c: &mut Criterion) {
    c.bench_function("message_passing_kanal_sync_api", |b| {
        let (sender, receiver) = kanal::bounded(0);

        let handle = thread::spawn(move || loop {
            if sender.send(777).is_err() {
                break;
            }
        });
        b.iter(|| {
            // Receiving the message
            let received = receiver.recv().unwrap();
            assert_eq!(received, 777);
        });
        drop(receiver);
        _ = handle.join();
    });
}

criterion_group!(
    benches,
    bench_message_passing_kanal_swait,
    bench_message_passing_kanal_sync_api,
    bench_swait_basic,
    bench_pollster_basic,
);
criterion_main!(benches);