pub fn kill(self) -> ThreadResult<()> {
        for worker in self.workers.iter() {
            worker.kill_signal.store(true, Ordering::SeqCst);
            worker.unparker.unpark();
        }

        self.join()
    }
/// Terminate the runtime and all worker threads without waiting for any
/// in-progress computation to complete.
///
/// Signals all workers to exit.  Any operators already running are
/// evaluated to completion, after which the worker thread terminates
/// even if the circuit has not been fully evaluated for the current
/// clock cycle.
Terminate the runtime and all worker threads without waiting for any
in-progress computation to complete.

Signals all workers to exit.  Any operators already running are
evaluated to completion, after which the worker thread terminates
even if the circuit has not been fully evaluated for the current
clock cycle.
Terminate the runtime and all worker threads without waiting for any in - progress computation to complete . Signals all workers to exit . Any operators already running are evaluated to completion after which the worker thread terminates even if the circuit has not been fully evaluated for the current clock cycle .
pub fn kill(self) -> ThreadResult<()> {
        for worker in self.workers.iter() {
            worker.kill_signal.store(true, Ordering::SeqCst);
            worker.unparker.unpark();
        }
        self.join()
    }
pub fn kill ( self ) -> ThreadResult < ( ) > { for worker in self . workers . iter ( ) { worker . kill_signal . store ( true , Ordering :: SeqCst ) ; worker . unparker . unpark ( ) ; } self . join ( ) }
Terminate the runtime and all worker threads without waiting for any
in-progress computation to complete.
Terminate the runtime and all worker threads without waiting for any in - progress computation to complete .
self