pub fn wait(mut self) {
        for thread_info in &mut self.thread_sync {
            if let Some((_, handle)) = thread_info.take() {
                let thread_name = handle.thread().name().unwrap_or("UNKNOWN").to_string();
                match handle.join() {
                    Ok(_) => {
                        log::trace!("Joined {}", thread_name);
                    }
                    Err(_) => {
                        log::error!("{} panicked while it ran", thread_name);
                    }
                }
            }
        }
    }
/// Blocks until all of the threads finish.
Blocks until all of the threads finish.
Blocks until all of the threads finish .
pub fn wait(mut self) {
        for thread_info in &mut self.thread_sync {
            if let Some((_, handle)) = thread_info.take() {
                let thread_name = handle.thread().name().unwrap_or("UNKNOWN").to_string();
                match handle.join() {
                    Ok(_) => {
                        log::trace!("Joined {}", thread_name);
                    }
                    Err(_) => {
                        log::error!("{} panicked while it ran", thread_name);
                    }
                }
            }
        }
    }
pub fn wait ( mut self ) { for thread_info in & mut self . thread_sync { if let Some ( ( _ , handle ) ) = thread_info . take ( ) { let thread_name = handle . thread ( ) . name ( ) . unwrap_or ( " " ) . to_string ( ) ; match handle . join ( ) { Ok ( _ ) => { log :: trace ! ( " " thread_name ) ; } Err ( _ ) => { log :: error ! ( " " thread_name ) ; } } } } }
Blocks until all of the threads finish.
Blocks until all of the threads finish .
mut self