Struct RcuArray 

pub struct RcuArray<T: Send + Sync + 'static> { /* private fields */ }

An array-like data structure that can be read without locking.

RcuArray provides a way to share a growable array between multiple threads. Writers create a new copy of the array when it needs to be grown, and readers are guaranteed to see a consistent snapshot of the array without blocking writers.

Implementations

impl<T: Send + Sync + 'static> RcuArray<T>

pub fn get<'a>(&self, scope: &'a RcuReadScope, index: usize) -> Option<&'a T>

Returns a reference to the element at the given index, or None if the index is out of bounds.

pub fn as_slice<'a>(&self, scope: &'a RcuReadScope) -> &'a [T]

Returns a slice containing the entire array.

pub unsafe fn ensure_at_least(&self, requested_size: usize)

where T: Clone + Default,

Ensures that the array has at least requested_size elements, filling with value if the array needs to be grown.

If the array is already large enough, this function does nothing. Otherwise, the array is grown to at least requested_size. To avoid frequent reallocations, the array will at least double in size.

Safety

Requires external synchronization to exclude concurrent writers.

pub fn update(&self, new_array: Vec<T>)

Updates the array to contain the given vector.

Trait Implementations

impl<T: Clone + Sync + Send + 'static> Clone for RcuArray<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Send + Sync + 'static> Debug for RcuArray<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Default + Send + Sync + 'static> Default for RcuArray<T>

fn default() -> RcuArray<T>

Returns the “default value” for a type.

impl<T: Send + Sync + 'static> From<Vec<T>> for RcuArray<T>

Creates an RcuArray from a Vec<T>.

fn from(value: Vec<T>) -> Self

Converts to this type from the input type.