/// Parks a thread until unpark_thread unparks it
Parks a thread until unpark_thread unparks it
Parks a thread until unpark_thread unparks it
pub fn park_thread(&self) {
        let _ = self
            .parked_threads
            .push(std::thread::current())
            .map(|_| {
                trace!("parking thread {:?}", std::thread::current().id());
                std::thread::park();
            })
            .map_err(|t| {
                debug!("couldn't park thread {:?}", t.id(),);
            });
    }
pub fn park_thread ( & self ) { let _ = self . parked_threads . push ( std :: thread :: current ( ) ) . map ( | _ | { trace ! ( " " std thread current ( ) id ( ) ) ; std :: thread :: park ( ) ; } ) . map_err ( | t | { debug ! ( " " t id ( ) ) ; } ) ; }
Parks a thread until unpark_thread unparks it
Parks a thread until unpark_thread unparks it
&self