Struct cros_async::blocking::pool::State
source · struct State {
tasks: VecDeque<Box<dyn FnOnce() + Send>>,
num_threads: usize,
num_idle: usize,
num_notified: usize,
worker_threads: Slab<JoinHandle<()>>,
exited_threads: Option<Receiver<usize>>,
exit: Sender<usize>,
shutting_down: bool,
}
Fields§
§tasks: VecDeque<Box<dyn FnOnce() + Send>>
§num_threads: usize
§num_idle: usize
§num_notified: usize
§worker_threads: Slab<JoinHandle<()>>
§exited_threads: Option<Receiver<usize>>
§exit: Sender<usize>
§shutting_down: bool
Auto Trait Implementations§
impl !RefUnwindSafe for State
impl Send for State
impl !Sync for State
impl Unpin for State
impl !UnwindSafe for State
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more