Struct stoplight::Thread

pub struct Thread<T> { /* fields omitted */ }

Handle to a stoppable thread.

Methods

impl<T> Thread<T> where
    T: Send + 'static, 

pub fn spawn<F>(f: F) -> Thread<T> where
    F: FnOnce(Arc<AtomicBool>) -> T + Send + 'static, 

Spawn a new job with cancelation.

pub fn join(self) -> Result<T, Box<dyn Any + Send + 'static>>

Join waits for the thread to exit then returns the return value.

pub fn stop(&self)

Signal the Thread to stop, To wait for the thread to exit call join.

pub fn thread(&self) -> &Thread

Extracts a handle to the underlying thread.

use stoplight;
use std::sync::atomic::{Ordering};

let th = stoplight::spawn(|stop| {
    while !stop.load(Ordering::Relaxed) {}
    42
});

let thread = th.thread();
eprintln!("thread id: {:?}", thread.id());