Struct RcuArc 

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

An RCU (Read-Copy-Update) version of Arc.

This Arc can be read from multiple threads concurrently without blocking. When the Arc is written, reads may continue to see the old value of the Arc for some period of time.

Implementations

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

pub fn new(data: Arc<T>) -> Self

Create a new RCU Arc from an Arc.

pub fn read(&self) -> RcuReadGuard<T>

Read the value of the RCU Arc.

The object referenced by the RCU Arc will remain valid until the RcuReadGuard is dropped. However, another thread running concurrently might see a different value for the object.

pub fn update(&self, data: Arc<T>)

Write the value of the RCU Arc.

Concurrent readers may continue to see the old value of the Arc until the RCU state machine has made sufficient progress to ensure that no concurrent readers are holding read guards.

pub fn to_arc(&self) -> Arc<T>

Create a new Arc to the object referenced by the RCU Arc.

This function returns a new Arc to the object referenced by the RCU Arc, increasing the reference count of the object by one.

Trait Implementations

impl<T: Send + Sync + 'static> Clone for RcuArc<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 RcuArc<T>

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

Formats the value using the given formatter.

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

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send + Sync + 'static> Drop for RcuArc<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send + Sync + 'static> From<Arc<T>> for RcuArc<T>

fn from(data: Arc<T>) -> Self

Converts to this type from the input type.