tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-09-07 00:00:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove deprecated benchmark

Browse Source
This commit is contained in:
Alex Crichton
2017-03-15 22:38:23 -07:00
parent c80953f078
commit 8383e8bf7a
1 changed files with 0 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
benches/latency.rs
-38
View File
@@ -14,7 +14,6 @@ use futures::sync::oneshot;
use futures::sync::mpsc; use futures::sync::mpsc;
use futures::{Future, Poll, Sink, Stream}; use futures::{Future, Poll, Sink, Stream};
use test::Bencher; use test::Bencher;
use tokio_core::channel::Sender;
use tokio_core::net::UdpSocket; use tokio_core::net::UdpSocket;
use tokio_core::reactor::Core; use tokio_core::reactor::Core;
@@ -95,43 +94,6 @@ fn udp_echo_latency(b: &mut Bencher) {
child.join().unwrap(); child.join().unwrap();
} }
#[bench]
fn tokio_channel_latency(b: &mut Bencher) {
let (tx, rx) = oneshot::channel();
let child = thread::spawn(move || {
let mut l = Core::new().unwrap();
let handle = l.handle();
let (in_tx, in_rx) = tokio_core::channel::channel(&handle).unwrap();
let (out_tx, out_rx) = tokio_core::channel::channel(&handle).unwrap();
tx.complete((in_tx, out_rx));
let server = out_tx.send_all(in_rx);
l.run(server).unwrap();
});
let (in_tx, out_rx) = rx.wait().unwrap();
let mut rx_iter = out_rx.wait();
// warmup phase; for some reason initial couple of runs are much slower
//
// TODO: Describe the exact reasons; caching? branch predictor? lazy closures?
for _ in 0..8 {
Sender::send(&in_tx, 1usize).unwrap();
let _ = rx_iter.next();
}
b.iter(|| {
Sender::send(&in_tx, 1usize).unwrap();
let _ = rx_iter.next();
});
drop(in_tx);
child.join().unwrap();
}
#[bench] #[bench]
fn futures_channel_latency(b: &mut Bencher) { fn futures_channel_latency(b: &mut Bencher) {
let (mut in_tx, in_rx) = mpsc::channel(32); let (mut in_tx, in_rx) = mpsc::channel(32);