Struct avr_oxide::concurrency::util::ThreadSet

#[repr(C)]
pub struct ThreadSet { /* private fields */ }

Implementations

impl ThreadSet

pub fn new() -> Self

pub fn add_thread(&mut self, isotoken: Isolated, id: ThreadId)

pub fn add_current_thread(&mut self, isotoken: Isolated)

pub fn remove_thread(&mut self, isotoken: Isolated, id: ThreadId)

pub fn remove_current_thread(&mut self, isotoken: Isolated)

pub fn contains_thread(&self, _isotoken: Isolated, id: ThreadId) -> bool

pub fn contains_current_thread(&self, isotoken: Isolated) -> bool

pub fn remove_all(&mut self)

pub fn do_each<F>(&self, isotoken: Isolated, f: F)

where F: FnMut(Isolated, ThreadId) -> bool,

Execute the given closure for each thread in this threadset.

The closure should return a boolean indicating if it should continue iterating through the threads.

pub fn do_each_consuming<F>(&mut self, isotoken: Isolated, f: F)

where F: FnMut(Isolated, ThreadId) -> bool,

Execute the given closure for each thread in this threadset. The thread is removed from the threadset following execution of the closure.

The closure should return a boolean indicating if it should continue iterating through the threads.