Struct Waker

pub(crate) struct Waker {
    selectors: Vec<Entry>,
    observers: Vec<Entry>,
}

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

A queue of threads blocked on channel operations.

This data structure is used by threads to register blocking operations and get woken up once an operation becomes ready.

Fields

selectors: Vec<Entry>

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

A list of select operations.

observers: Vec<Entry>

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

A list of operations waiting to be ready.

Implementations

impl Waker

pub(crate) fn new() -> Self

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Creates a new Waker.

pub(crate) fn register(&mut self, oper: Operation, cx: &Context)

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Registers a select operation.

pub(crate) fn register_with_packet( &mut self, oper: Operation, packet: *mut (), cx: &Context, )

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Registers a select operation and a packet.

pub(crate) fn unregister(&mut self, oper: Operation) -> Option<Entry>

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Unregisters a select operation.

pub(crate) fn try_select(&mut self) -> Option<Entry>

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Attempts to find another thread’s entry, select the operation, and wake it up.

pub(crate) fn notify(&mut self)

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Notifies all operations waiting to be ready.

pub(crate) fn disconnect(&mut self)

🔬This is a nightly-only experimental API. (mpmc_channel #126840)

Notifies all registered operations that the channel is disconnected.

Trait Implementations

impl Drop for Waker

fn drop(&mut self)

Executes the destructor for this type.