Struct tikv_util::mpsc::batch::State

struct State {
    recv_task: AtomicPtr<Waker>,
    notify_size: usize,
    pending: AtomicUsize,
    notifier_registered: AtomicBool,
}

Fields

recv_task: AtomicPtr<Waker>

notify_size: usize

pending: AtomicUsize

notifier_registered: AtomicBool

Implementations

impl State

fn new(notify_size: usize) -> State

fn try_notify_post_send(&self)

fn notify(&self)

fn yield_poll(&self, waker: Waker) -> bool

When the Receiver that holds the State is running on an Executor, the Receiver calls this to yield from the current poll context, and puts the current task handle to recv_task, so that the Sender respectively can notify it after sending some messages into the channel.

Trait Implementations

impl Drop for State

fn drop(&mut self)

Executes the destructor for this type.