Struct ArcRecursive 

pub struct ArcRecursive<T>(pub Arc<Mutex<Option<T>>>);

Available on crate feature std only.

Thread-safe recursive anchor type — the RcRecursive counterpart for cross-thread / parallel-parse use cases.

Wraps Arc<Mutex<Option<T>>>. Access through ArcRecursive::lock (rather than a Deref) so the locking is explicit at the call site.

Examples

use noyalib::ArcRecursive;
let r: ArcRecursive<i32> = ArcRecursive::new(42);
assert_eq!(*r.lock(), Some(42));

Tuple Fields

0: Arc<Mutex<Option<T>>>

Implementations

impl<T> ArcRecursive<T>

pub fn empty() -> Self

Construct an empty (uninitialised) thread-safe recursive anchor.

pub fn new(value: T) -> Self

Construct a thread-safe recursive anchor pre-populated with value.

pub fn lock(&self) -> MutexGuard<'_, Option<T>>

Lock the inner cell. Recovers from poisoning rather than panicking — the only way the mutex gets poisoned is a panic mid-write inside the critical section, and the recovered guard is still observable as None or as the pre-panic value.

Returns a MutexGuard over Option<T>.

Examples

use noyalib::ArcRecursive;
let r = ArcRecursive::new("hi".to_string());
let guard = r.lock();
assert_eq!(guard.as_deref(), Some("hi"));

pub fn set(&self, value: T) -> Option<T>

Replace the inner value, returning the previous one if any.

pub fn take(&self) -> Option<T>

Drop the inner value, returning it if any.

pub fn strong_count(&self) -> usize

Number of strong Arc references to this recursive cell.

pub fn downgrade(&self) -> ArcRecursion<T>

Downgrade to an ArcRecursion weak reference.

Trait Implementations

impl<T> Clone for ArcRecursive<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> Debug for ArcRecursive<T>

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

Formats the value using the given formatter.

impl<T> Default for ArcRecursive<T>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, T: Deserialize<'de>> Deserialize<'de> for ArcRecursive<T>

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: Serialize> Serialize for ArcRecursive<T>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.