mirror of
https://github.com/tokio-rs/tokio.git
synced 2025-10-01 12:20:39 +00:00
parent
3235749006
commit
272e09d349
@ -27,7 +27,6 @@ rand = "0.6"
|
|||||||
log = "0.4"
|
log = "0.4"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
tokio-timer = "0.1"
|
|
||||||
env_logger = "0.5"
|
env_logger = "0.5"
|
||||||
|
|
||||||
# For comparison benchmarks
|
# For comparison benchmarks
|
||||||
|
@ -1,34 +0,0 @@
|
|||||||
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));
|
|
||||||
}
|
|
Loading…
x
Reference in New Issue
Block a user