itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Optimize next_timeout slightly

Browse Source 
Avoid moves as it apparently adversely affects perf
This commit is contained in:
Alex Crichton 2016-08-13 23:29:08 -07:00
parent 3158a2c73b
commit 8327d327c1
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/timer_wheel.rs
View File

@ -231,21 +231,22 @@ impl<T> TimerWheel<T> {
/// scheduled in this wheel.
pub fn next_timeout(&self) -> Option<Instant> {
// TODO: can this be optimized to not look at the whole array?
let timeouts = self.wheel.iter().map(|slot| slot.next_timeout);
let min = timeouts.fold(None, |prev, cur| {
match (prev, cur) {
(None, cur) => cur,
(Some(time), None) => Some(time),
(Some(a), Some(b)) => Some(cmp::min(a, b)),
let mut min = None;
for a in self.wheel.iter().filter_map(|s| s.next_timeout.as_ref()) {
if let Some(b) = min {
if b < a {
continue
}
}
});
min = Some(a);
}
if let Some(min) = min {
debug!("next timeout {:?}", min);
debug!("now {:?}", Instant::now());
} else {
debug!("next timeout never");
}
return min
min.map(|t| *t)
}
/// Cancels the specified timeout.