Function channel 

pub fn channel<T: Send + 'static>(
    capacity: usize,
) -> (ChannelProducer<T>, ChannelConsumer<T>)

Create a bounded in-process queue with room for capacity pending items.