Struct ChannelInner 

pub struct ChannelInner {
    pub queue: Mutex<ChannelState>,
    pub not_empty: Condvar,
    pub not_full: Condvar,
    pub capacity: usize,
    pub waiters: Mutex<Vec<Wake>>,
}

Fields

queue: Mutex<ChannelState>

not_empty: Condvar

not_full: Condvar

capacity: usize

waiters: Mutex<Vec<Wake>>

Wakers of fibers waiting to send or receive; all are woken on any change. Registered while holding queue, so a change made after the check cannot be missed.

Implementations

impl ChannelInner

pub fn wake_fibers(&self)

Wakes every fiber waiting on the channel.