Struct RcuOptionArc 

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

An RCU (Read-Copy-Update) wrapper around Option<Arc<T>>.

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> RcuOptionArc<T>

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

Create a new RCU wrapper around an Option<Arc<T>>.

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

Read the value of the wrapped Arc, if present.

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) -> Option<&'a T>

Returns a reference to the value of the wrapped Arc, if present.

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: Option<Arc<T>>)

Write a new Option<Arc<T>> 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 to_option_arc(&self) -> Option<Arc<T>>

Create a new Arc<T> to the object referenced by the wrapped Arc, if present.

This function returns a new Option<Arc<T>> to the object referenced by the wrapped Arc, potentially increasing the reference count of the object by one.

Trait Implementations

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

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

Formats the value using the given formatter.

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

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send + Sync + 'static> Drop for RcuOptionArc<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<Option<Arc<T>>> for RcuOptionArc<T>

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

Converts to this type from the input type.