pub fn run_workers(&self) {
        let mut workers = self.running_workers.lock().unwrap();
        workers.extend(self.new_workers.lock().unwrap().drain(..));
        workers.iter_mut().for_each(|worker| worker.do_work());
        workers.retain(|worker| worker.should_keep_working());
    }
/// Run all the workers that have been added and are alive. This function
/// should not be run in the Realtime thread. Additionally, there is no
/// benefit to running it in parallel as concurrency is limited to 1 worker
/// at a time.
Run all the workers that have been added and are alive. This function
should not be run in the Realtime thread. Additionally, there is no
benefit to running it in parallel as concurrency is limited to 1 worker
at a time.
Run all the workers that have been added and are alive . This function should not be run in the Realtime thread . Additionally there is no benefit to running it in parallel as concurrency is limited to 1 worker at a time .
pub fn run_workers(&self) {
        let mut workers = self.running_workers.lock().unwrap();
        workers.extend(self.new_workers.lock().unwrap().drain(..));
        workers.iter_mut().for_each(|worker| worker.do_work());
        workers.retain(|worker| worker.should_keep_working());
    }
pub fn run_workers ( & self ) { let mut workers = self . running_workers . lock ( ) . unwrap ( ) ; workers . extend ( self . new_workers . lock ( ) . unwrap ( ) . drain ( .. ) ) ; workers . iter_mut ( ) . for_each ( | worker | worker . do_work ( ) ) ; workers . retain ( | worker | worker . should_keep_working ( ) ) ; }
Run all the workers that have been added and are alive.
Run all the workers that have been added and are alive .
&self
&self