Struct ThreadWakeBatch 

pub struct ThreadWakeBatch { /* private fields */ }

A task-context wake list backed by nodes embedded in each thread core.

Queue owners add handles while holding their own metadata lock, release that lock, and then call Self::wake_all. This is the same ownership split as Linux wake_q: unlink and select atomically under the domain lock, perform scheduler wakes afterwards, and never allocate in between.

A thread can occur at most once in all live batches. Duplicate insertion is coalesced and returns false. The batch is deliberately neither Send nor Sync; the task context that selected the waiters must drain it.

Implementations

impl ThreadWakeBatch

pub const fn new() -> Self

Creates an empty batch without allocating.

pub fn push(&mut self, wake: ThreadWakeHandle) -> bool

Adds a wake handle, returning false when this thread is already in a live batch.

pub const fn len(&self) -> usize

Returns the number of unique threads selected by this batch.

pub const fn is_empty(&self) -> bool

Returns whether no thread has been selected.

pub fn wake_all(self) -> usize

Wakes all selected threads in FIFO order.

Trait Implementations

impl Default for ThreadWakeBatch

fn default() -> Self

Returns the “default value” for a type.

impl Drop for ThreadWakeBatch

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.