add benches for timer extension

add benchmarks specifically targeting the use-case
of extending a timer by removing and re-registering

Cargo.toml

@@ -34,6 +34,7 @@ nix = { version = "0.29", default-features = false, features = ["signal"], optio
 [dev-dependencies]
 futures = "0.3.5"
 rustix = { version = "0.38", default-features = false, features = ["net"] }
+criterion = { version = "0.4" }
 
 [features]
 block_on = ["pin-utils"]
@@ -48,3 +49,7 @@ rustdoc-args = ["--cfg", "docsrs"]
 [[test]]
 name = "signals"
 harness = false
+
+[[bench]]
+name = "timer"
+harness = false

benches/timer.rs

@@ -0,0 +1,100 @@
+use std::time::Duration;
+
+use calloop::timer::TimeoutAction;
+use criterion::{criterion_group, criterion_main, Criterion};
+
+fn single(c: &mut Criterion) {
+    let mut event_loop = calloop::EventLoop::<()>::try_new().unwrap();
+    let loop_handle = event_loop.handle();
+
+    let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+    let mut timeout_token = loop_handle
+        .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+        .unwrap();
+
+    c.bench_function("extend_single", |b| {
+        b.iter(|| {
+            loop_handle.remove(timeout_token);
+
+            let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+            timeout_token = loop_handle
+                .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+                .unwrap();
+
+            event_loop.dispatch(Some(Duration::ZERO), &mut ()).unwrap();
+        });
+    });
+}
+
+fn mixed(c: &mut Criterion) {
+    let mut event_loop = calloop::EventLoop::<()>::try_new().unwrap();
+    let loop_handle = event_loop.handle();
+
+    let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10 - 1));
+    loop_handle
+        .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+        .unwrap();
+
+    let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+    let mut timeout_token = loop_handle
+        .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+        .unwrap();
+
+    let timer = calloop::timer::Timer::from_duration(Duration::from_secs(90 * 10));
+    loop_handle
+        .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+        .unwrap();
+
+    c.bench_function("extend_mixed", |b| {
+        b.iter(|| {
+            loop_handle.remove(timeout_token);
+
+            let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+            timeout_token = loop_handle
+                .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+                .unwrap();
+
+            event_loop.dispatch(Some(Duration::ZERO), &mut ()).unwrap();
+        });
+    });
+}
+
+fn mixed_multiple(c: &mut Criterion) {
+    let mut event_loop = calloop::EventLoop::<()>::try_new().unwrap();
+    let loop_handle = event_loop.handle();
+
+    for _ in 0..1000 {
+        let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10 - 1));
+        loop_handle
+            .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+            .unwrap();
+    }
+
+    let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+    let mut timeout_token = loop_handle
+        .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+        .unwrap();
+
+    for _ in 0..1000 {
+        let timer = calloop::timer::Timer::from_duration(Duration::from_secs(90 * 10));
+        loop_handle
+            .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+            .unwrap();
+    }
+
+    c.bench_function("extend_mixed_many", |b| {
+        b.iter(|| {
+            loop_handle.remove(timeout_token);
+
+            let timer = calloop::timer::Timer::from_duration(Duration::from_secs(60 * 10));
+            timeout_token = loop_handle
+                .insert_source(timer, |_, _, _| TimeoutAction::Drop)
+                .unwrap();
+
+            event_loop.dispatch(Some(Duration::ZERO), &mut ()).unwrap();
+        });
+    });
+}
+
+criterion_group!(benches, single, mixed, mixed_multiple);
+criterion_main!(benches);