Struct AtomicWaker 

pub struct AtomicWaker { /* private fields */ }

Atomic waker storage with state machine synchronization

带有状态机同步的原子 waker 存储

Implementations

impl AtomicWaker

pub fn new() -> Self

Create a new atomic waker

创建一个新的原子 waker

pub fn register(&self, waker: &Waker)

Register a waker to be notified

This will store the waker and handle concurrent access safely. If a concurrent wake happens during registration, the newly registered waker will be woken immediately.

注册一个要通知的 waker

这将存储 waker 并安全地处理并发访问。 如果在注册期间发生并发唤醒，新注册的 waker 将立即被唤醒。

pub fn take(&self) -> Option<Waker>

Take the waker out for waking

Returns the waker if one was registered, None otherwise. This atomically removes the waker from storage.

取出 waker 用于唤醒

如果注册了 waker 则返回它，否则返回 None。 这会原子地从存储中移除 waker。

pub fn wake(&self)

Wake the registered waker if any

唤醒已注册的 waker（如果有）

Trait Implementations

impl Debug for AtomicWaker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for AtomicWaker

fn drop(&mut self)

Executes the destructor for this type.

impl Send for AtomicWaker

impl Sync for AtomicWaker