Struct crossbeam_channel::waker::SyncWaker

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

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>

The inner Waker.

is_empty: AtomicBool

true if the waker is empty.

Implementations

impl SyncWaker

pub(crate) fn new() -> Self

Creates a new SyncWaker.

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

Registers the current thread with an operation.

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

Unregisters an operation previously registered by the current thread.

pub(crate) fn notify(&self)

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

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

Registers an operation waiting to be ready.

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

Unregisters an operation waiting to be ready.

pub(crate) fn disconnect(&self)

Notifies all threads that the channel is disconnected.

Trait Implementations

impl Drop for SyncWaker

fn drop(&mut self)

Executes the destructor for this type.