Struct ConcurrentVec 

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

A simple concurrent vector type supporting push operations that do not block reads. Concurrent pushes are serialized, but reads need not wait for writes to complete, except when the vector needs to be resized.

Implementations

impl<T> ConcurrentVec<T>

pub fn new() -> Self

Create a new AsyncVec with the default capacity (128).

pub fn with_capacity(capacity: usize) -> Self

Create a new AsyncVec with the given starting capacity.

pub fn push(&self, item: T) -> usize

Push item onto the vector. Other calls to push may have to complete in order for this item to be visible.

pub fn read(&self) -> impl Deref<Target = [T]> + '_

Trait Implementations

impl<T> Default for ConcurrentVec<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Drop for ConcurrentVec<T>

fn drop(&mut self)

Executes the destructor for this type.