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,
            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) -> TotalTimeProfiler<F>

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
) -> TotalTimeProfiler<PeriodicReporter<F>>

pub fn periodically(
    period: Duration,
    f: F
) -> TotalTimeProfiler<PeriodicReporter<F>>

Trait Implementations

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

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

Formats the value using the given formatter.

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

pub fn start(&mut self)

pub fn end(&mut self)