pub fn stop(&mut self) {
        for thread_info in &mut self.thread_sync {
            if let Some((tx, handle)) = thread_info.take() {
                drop(tx);
                let thread_name = handle.thread().name().unwrap_or("UNKNOWN").to_string();
                match handle.join() {
                    Ok(_) => {
                        log::debug!("Joined {}", thread_name);
                    }
                    Err(_) => {
                        log::error!("{} panicked while it ran", thread_name);
                    }
                }
            }
        }
    }
/// Signals each thread to stop, then blocks until they have stopped.
///
/// Threads have to check to see if they have been signaled using their notifier.
Signals each thread to stop, then blocks until they have stopped.
Threads have to check to see if they have been signaled using their notifier.
Signals each thread to stop then blocks until they have stopped . Threads have to check to see if they have been signaled using their notifier .
pub fn stop(&mut self) {
        for thread_info in &mut self.thread_sync {
            if let Some((tx, handle)) = thread_info.take() {
                drop(tx);
                let thread_name = handle.thread().name().unwrap_or("UNKNOWN").to_string();
                match handle.join() {
                    Ok(_) => {
                        log::debug!("Joined {}", thread_name);
                    }
                    Err(_) => {
                        log::error!("{} panicked while it ran", thread_name);
                    }
                }
            }
        }
    }
pub fn stop ( & mut self ) { for thread_info in & mut self . thread_sync { if let Some ( ( tx , handle ) ) = thread_info . take ( ) { drop ( tx ) ; let thread_name = handle . thread ( ) . name ( ) . unwrap_or ( " " ) . to_string ( ) ; match handle . join ( ) { Ok ( _ ) => { log :: debug ! ( " " thread_name ) ; } Err ( _ ) => { log :: error ! ( " " thread_name ) ; } } } } }
Signals each thread to stop, then blocks until they have stopped.
Signals each thread to stop then blocks until they have stopped .
&mut self