latency_trace 0.6.0

supports latency measurement for functions and code blocks, both sync and async.
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

//! `tokio`-related latency reporting methods of [`crate::lt_collect_g::LatencyTraceG`].
//! Present only when the **"tokio"** feature flag is enabled.

use crate::{
    lt_collect_g::LatencyTraceG,
    lt_refine_g::Timings,
    tlc_param::{TlcDirect, TlcParam},
};
use std::future::Future;

impl<P> LatencyTraceG<P>
where
    P: TlcParam,
    P::Control: TlcDirect,
{
    /// Executes the instrumented async function `f`, running on the `tokio` runtime; after `f` completes,
    /// returns the observed latencies.
    /// Present only when the **"tokio"** feature flag is enabled.
    pub fn measure_latencies_tokio<F>(&self, f: impl FnOnce() -> F) -> Timings
    where
        F: Future<Output = ()> + Send,
    {
        self.measure_latencies(move || {
            tokio::runtime::Builder::new_multi_thread()
                .enable_all()
                .build()
                .expect("Tokio runtime error")
                .block_on(f());
        })
    }
}