Struct dpc_pariter::TotalTimeProfiler

pub struct TotalTimeProfiler<Reporter> { /* private fields */ }

A simple basic profiler implementation which tracks the accumulative time and calls a handler function with it.

Example

use dpc_pariter::{IteratorExt, TotalTimeProfiler};

dpc_pariter::scope(|scope| {
    (0..22)
        .readahead_scoped_profiled(
            scope,
            0,
            TotalTimeProfiler::periodically_millis(10_000, || eprintln!("Blocked on sending")),
            TotalTimeProfiler::periodically_millis(10_000, || eprintln!("Blocked on receving")),
        )
        .for_each(|i| {
            println!("{i}");
        })
})
.expect("thread panicked");

Implementations

impl<F> TotalTimeProfiler<F> where
    F: for<'a> Fn(&'a mut TotalTimeStats), 

pub fn new(f: F) -> Self

Create a TotalTimeProfiler with any handle

Example

use dpc_pariter::{IteratorExt, TotalTimeProfiler};

let profiler = TotalTimeProfiler::new(|stats| eprintln!("accumulative sending time so far: {}", stats.total().as_millis()));

impl<F> TotalTimeProfiler<PeriodicReporter<F>> where
    F: Fn(), 

pub fn periodically_millis(millis: u64, f: F) -> Self

pub fn periodically(period: Duration, f: F) -> Self

Trait Implementations

impl<Reporter: Debug> Debug for TotalTimeProfiler<Reporter>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Reporter> Profiler for TotalTimeProfiler<Reporter> where
    Reporter: Reporter, 

fn start(&mut self)

fn end(&mut self)