Struct RcuArc 

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

An RCU (Read-Copy-Update) wrapper around an Arc.

The Arc can be dereferenced from multiple threads concurrently without blocking. When the Arc is replaced, reads may continue to see the old Arc pointer for some period of time.

Implementations

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

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

Create a new RCU wrapper around an Arc.

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

Read the value of the wrapped 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 as_ref<'a>(&self, scope: &'a RcuReadScope) -> &'a T

Returns a reference to the value of the wrapped Arc.

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

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

Write a new Arc to the RCU wrapper.

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

pub fn update_swap<'a>(&self, scope: &'a RcuReadScope, data: Arc<T>) -> &'a T

Write a new Arc to the RCU wrapper and return a reference to the old value.

Concurrent readers may continue to see the old Arc pointer 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 wrapped Arc.

This function returns a new Arc to the object referenced by the wrapped 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.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

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.