Struct SyncWaker

pub(crate) struct SyncWaker {
    inner: Mutex<Waker>,
    is_empty: Atomic<bool>,
}

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

A waker that can be shared among threads without locking.

This is a simple wrapper around Waker that internally uses a mutex for synchronization.

Fields

inner: Mutex<Waker>

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

The inner Waker.

is_empty: Atomic<bool>

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

true if the waker is empty.

Implementations

impl SyncWaker

pub(crate) fn new() -> Self

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

Creates a new SyncWaker.

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

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

Registers the current thread with an operation.

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

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

Unregisters an operation previously registered by the current thread.

pub(crate) fn notify(&self)

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

Attempts to find one thread (not the current one), select its operation, and wake it up.

pub(crate) fn disconnect(&self)

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

Notifies all threads that the channel is disconnected.

Trait Implementations

impl Drop for SyncWaker

fn drop(&mut self)

Executes the destructor for this type.