[go: up one dir, main page]

tokio 0.1.17

An event-driven, non-blocking I/O platform for writing asynchronous I/O backed applications.
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

// Measure cost of different operations
// to get a sense of performance tradeoffs
#![feature(test)]
#![deny(warnings)]

extern crate mio;
extern crate test;

use test::Bencher;

use mio::tcp::TcpListener;
use mio::{PollOpt, Ready, Token};

#[bench]
fn mio_register_deregister(b: &mut Bencher) {
    let addr = "127.0.0.1:0".parse().unwrap();
    // Setup the server socket
    let sock = TcpListener::bind(&addr).unwrap();
    let poll = mio::Poll::new().unwrap();

    const CLIENT: Token = Token(1);

    b.iter(|| {
        poll.register(&sock, CLIENT, Ready::readable(), PollOpt::edge())
            .unwrap();
        poll.deregister(&sock).unwrap();
    });
}

#[bench]
fn mio_reregister(b: &mut Bencher) {
    let addr = "127.0.0.1:0".parse().unwrap();
    // Setup the server socket
    let sock = TcpListener::bind(&addr).unwrap();
    let poll = mio::Poll::new().unwrap();

    const CLIENT: Token = Token(1);
    poll.register(&sock, CLIENT, Ready::readable(), PollOpt::edge())
        .unwrap();

    b.iter(|| {
        poll.reregister(&sock, CLIENT, Ready::readable(), PollOpt::edge())
            .unwrap();
    });
    poll.deregister(&sock).unwrap();
}

#[bench]
fn mio_poll(b: &mut Bencher) {
    let poll = mio::Poll::new().unwrap();
    let timeout = std::time::Duration::new(0, 0);
    let mut events = mio::Events::with_capacity(1024);

    b.iter(|| {
        poll.poll(&mut events, Some(timeout)).unwrap();
    });
}