Struct spmc_buffer::SPMCBuffer

pub struct SPMCBuffer<T: Clone + PartialEq + Send> { /* fields omitted */ }

A single-producer multiple-consumer buffer, useful for thread-safe data sharing in scenarios where triple buffering won't cut it.

Triple buffering is an extremely efficient synchronization protocol when a producer thread wants to constantly update a value that is visible by a single consumer thread. However, it is not safe to use in the presence of multiple consumers, because a consumer thread can no longer assume that it is the only thread having access to the read buffer and discard said read buffer at will.

Reference counting techniques can be used to build a variant of triple buffering which works for multiple consumers, remains provably wait-free if one uses two buffers per consumer, and degrades gracefully when a smaller amount of buffers is used as long as consumers frequently fetch updates from the producer. I call the resulting synchronization primitive an SPMC buffer.

Methods

impl<T: Clone + PartialEq + Send> SPMCBuffer<T>

fn new(wf_read_concurrency: usize, initial: T) -> Self

Construct an SPMC buffer allowing for wait-free writes under up to N concurrent readouts to distinct buffer versions

fn split(self) -> (SPMCBufferInput<T>, SPMCBufferOutput<T>)

Extract input and output of the SPMC buffer

Trait Implementations

impl<T: Debug + Clone + PartialEq + Send> Debug for SPMCBuffer<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T: Clone + PartialEq + Send> Clone for SPMCBuffer<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Clone + PartialEq + Send> PartialEq for SPMCBuffer<T>

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.