Struct BufferedChannel 

pub struct BufferedChannel<T: Send> {
    pub chunk_size: usize,
    /* private fields */
}

An asynchronous MPSC channel that buffers messages and reuses allocations with thread locals.

This is a building block for efficient parallel worker tasks.

Cache this channel in a system’s Local to reuse allocated memory.

This is faster than sending each message individually into a channel when communicating between tasks. Unlike Parallel, this allows you to execute a consuming task while producing tasks are concurrently sending data into the channel, enabling you to run a serial processing consumer at the same time as many parallel processing producers.

Fields

chunk_size: usize

The minimum length of a Vec of buffered data before it is sent through the channel.

Implementations

impl<T: Send> BufferedChannel<T>

pub fn unbounded(&self) -> (BufferedReceiver<'_, T>, BufferedSender<'_, T>)

Create an unbounded channel and return the receiver and sender.

The created channel can hold an unlimited number of messages.

pub fn bounded( &self, cap: usize, ) -> (BufferedReceiver<'_, T>, BufferedSender<'_, T>)

Create a bounded channel and return the receiver and sender.

The created channel has space to hold at most cap messages at a time.

Panics

Capacity must be a positive number. If cap is zero, this function will panic.

Trait Implementations

impl<T: Send> Default for BufferedChannel<T>

fn default() -> Self

Returns the “default value” for a type.