pub fn shutdown(&self) {
        self.drain_remotely_completed_tasks();

        // Abort all incomplete tasks.
        let running_tasks = unsafe { &mut *self.running_tasks.get() };
        for (_, task) in running_tasks.iter() {
            task.abort();
        }
        running_tasks.clear();

        unsafe {
            *self.park.get() = None;
            *self.unpark.get() = None;
        }
    }
/// Drops the remaining incomplete tasks and the parker associated with this worker.
///
/// This function is called by the shutdown trigger.
Drops the remaining incomplete tasks and the parker associated with this worker.
This function is called by the shutdown trigger.
Drops the remaining incomplete tasks and the parker associated with this worker . This function is called by the shutdown trigger .
pub fn shutdown(&self) {
        self.drain_remotely_completed_tasks();
        // Abort all incomplete tasks.
        let running_tasks = unsafe { &mut *self.running_tasks.get() };
        for (_, task) in running_tasks.iter() {
            task.abort();
        }
        running_tasks.clear();
        unsafe {
            *self.park.get() = None;
            *self.unpark.get() = None;
        }
    }
pub fn shutdown ( & self ) { self . drain_remotely_completed_tasks ( ) ; // Abort all incomplete tasks. let running_tasks = unsafe { & mut * self . running_tasks . get ( ) } ; for ( _ , task ) in running_tasks . iter ( ) { task . abort ( ) ; } running_tasks . clear ( ) ; unsafe { * self . park . get ( ) = None ; * self . unpark . get ( ) = None ; } }
Drops the remaining incomplete tasks and the parker associated with this worker.
Drops the remaining incomplete tasks and the parker associated with this worker .
&self