Struct RunningProgressPoints 

pub struct RunningProgressPoints { /* private fields */ }

Worker-side handle for reporting running progress points.

RunningProgressPoints deliberately cannot stop or join the reporter thread. It only wakes the reporter loop for zero-interval progress. For positive intervals, Self::running_point is a no-op because the reporter loop wakes itself on timeout.

Examples

use std::{
    thread,
    time::Duration,
};

use qubit_progress::{
    NoOpProgressReporter,
    Progress,
    ProgressCounters,
    RunningProgressLoop,
};

let reporter = NoOpProgressReporter;

thread::scope(|scope| {
    let progress = Progress::new(&reporter, Duration::ZERO);
    let running_progress =
        RunningProgressLoop::spawn_scoped(scope, progress, || {
            ProgressCounters::new(Some(1)).with_completed_count(1)
        });
    let progress_points = running_progress.points();

    assert!(progress_points.running_point());

    running_progress.stop_and_join();
});

Author

Haixing Hu

Implementations

impl RunningProgressPoints

pub fn running_point(&self) -> bool

Reports one worker running progress point.

Returns

true when the point was accepted or no point signal is required. Returns false only when a required zero-interval signal could not be sent because the reporter loop has already stopped.

Trait Implementations

impl Clone for RunningProgressPoints

fn clone(&self) -> RunningProgressPoints

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.