Struct tokio::runtime::scheduler::multi_thread::idle::Idle

pub(super) struct Idle {
    state: AtomicUsize,
    num_workers: usize,
}

Fields

state: AtomicUsize

Tracks both the number of searching workers and the number of unparked workers.

Used as a fast-path to avoid acquiring the lock when needed.

num_workers: usize

Total number of workers.

Implementations

impl Idle

pub(super) fn new(num_workers: usize) -> (Idle, Synced)

pub(super) fn worker_to_notify(&self, shared: &Shared) -> Option<usize>

If there are no workers actively searching, returns the index of a worker currently sleeping.

pub(super) fn transition_worker_to_parked( &self, shared: &Shared, worker: usize, is_searching: bool, ) -> bool

Returns true if the worker needs to do a final check for submitted work.

pub(super) fn transition_worker_to_searching(&self) -> bool

pub(super) fn transition_worker_from_searching(&self) -> bool

A lightweight transition from searching -> running.

Returns true if this is the final searching worker. The caller must notify a new worker.

pub(super) fn unpark_worker_by_id( &self, shared: &Shared, worker_id: usize, ) -> bool

Unpark a specific worker. This happens if tasks are submitted from within the worker’s park routine.

Returns true if the worker was parked before calling the method.

pub(super) fn is_parked(&self, shared: &Shared, worker_id: usize) -> bool

Returns true if worker_id is contained in the sleep set.

fn notify_should_wakeup(&self) -> bool