benches/spawn.rs


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

#![feature(test)]

extern crate test;

use futures::channel::oneshot;
use futures::executor;
use futures::future::TryFutureExt;
use test::Bencher;

#[bench]
fn task_create(b: &mut Bencher) {
    b.iter(|| {
        async_task::spawn(async {}, drop);
    });
}

#[bench]
fn task_run(b: &mut Bencher) {
    b.iter(|| {
        let (runnable, handle) = async_task::spawn(async {}, drop);
        runnable.run();
        executor::block_on(handle).unwrap();
    });
}

#[bench]
fn oneshot_create(b: &mut Bencher) {
    b.iter(|| {
        let (tx, _rx) = oneshot::channel::<()>();
        let _task = Box::new(async move { tx.send(()).map_err(|_| ()) });
    });
}

#[bench]
fn oneshot_run(b: &mut Bencher) {
    b.iter(|| {
        let (tx, rx) = oneshot::channel::<()>();
        let runnable = Box::new(async move { tx.send(()).map_err(|_| ()) });

        let future = runnable.and_then(|_| rx.map_err(|_| ()));
        executor::block_on(future).unwrap();
    });
}