tokio-threadpool 0.1.8

A task scheduler backed by a work-stealing thread pool.
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

extern crate futures;
extern crate tokio_threadpool;
extern crate tokio_timer;
extern crate env_logger;

use tokio_threadpool::*;
use tokio_timer::Timer;

use futures::*;
use futures::sync::oneshot::spawn;

use std::thread;
use std::time::Duration;

pub fn main() {
    let _ = ::env_logger::init();

    let timer = Timer::default();
    {
        let pool = ThreadPool::new();
        let tx = pool.sender().clone();

        let fut = timer.interval(Duration::from_millis(300))
            .for_each(|_| {
                println!("~~~~~ Hello ~~~");
                Ok(())
            })
            .map_err(|_| unimplemented!());

        spawn(fut, &tx).wait().unwrap();
    }

    thread::sleep(Duration::from_millis(100));
}