Struct VecBelt 

pub struct VecBelt<T> { /* private fields */ }

A high-performant, concurrent, lock-free data structure suitable for multi-threaded bulk-appending (takes a &self) and single-threaded consuming (takes a &mut self).

See the module-level documentation for more details.

Implementations

impl<T> VecBelt<T>

pub fn new(initial_size: usize) -> Self

Creates a new VecBelt<T>, preallocating a fragment of the given initial size.

pub fn len(&self) -> usize

Reads the length of the vector atomically. Prefer len_mut if possible.

pub fn is_empty(&self) -> bool

Tests whether the vector is empty atomically. Prefer is_empty_mut if possible.

pub fn len_mut(&mut self) -> usize

Reads the length of the vector non-atomically via &mut self.

pub fn is_empty_mut(&mut self) -> bool

Tests whether the vector is empty non-atomically via &mut self.

pub unsafe fn append_raw( &self, additional: usize, acceptor: impl FnOnce(*mut T), ) -> usize

Extends the vector by additional elements, invoking a closure with an uninitialized slice to it and the starting element’s absolute index in the vector.

Safety

• additional must be less or equal to isize::MAX.
• acceptor must fully initialize and not read the given pointer for additional consecutive items. Notably, this means panic!(..)-ing mid-way will lead to undefined behavior due to uninitialized elements present.

pub fn append(&self, transfer: impl Transfer<T>) -> usize

Appends a slice to this vector, returning the absolute index of the first element.

pub fn clear<'a, R>( &'a mut self, consumer: impl FnOnce(ConsumeSlice<'a, T>) -> R, ) -> R

Flattens the vector (if it isn’t flattened already), invokes a closure with an owned slice, and clears the vector.

Trait Implementations

impl<T> Debug for VecBelt<T>

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

Formats the value using the given formatter.

impl<T> Drop for VecBelt<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> RefUnwindSafe for VecBelt<T>

impl<T: Send> Send for VecBelt<T>

Safety

VecBelt<T> provides synchronization primitives that won’t lead to data races.

impl<T: Send> Sync for VecBelt<T>

Safety

T: Sync isn’t necessary here, because there is guaranteed not to be references to the same elements across threads.

impl<T> UnwindSafe for VecBelt<T>