Struct crossbeam_channel::waker::Waker

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

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>

A list of select operations.

observers: Vec<Entry>

A list of operations waiting to be ready.

Implementations

impl Waker

pub(crate) fn new() -> Self

Creates a new Waker.

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

Registers a select operation.

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

Registers a select operation and a packet.

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

Unregisters a select operation.

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

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

pub(crate) fn can_select(&self) -> bool

Returns true if there is an entry which can be selected by the current thread.

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

Registers an operation waiting to be ready.

pub(crate) fn unwatch(&mut self, oper: Operation)

Unregisters an operation waiting to be ready.

pub(crate) fn notify(&mut self)

Notifies all operations waiting to be ready.

pub(crate) fn disconnect(&mut self)

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.