castbox 0.1.4

A Runtime-Typed Reference-Counted Smart Pointer and Concurrent Programming tools.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use crossync::sync::RwLock;
use std::any::Any;
use std::marker::PhantomData;
use std::sync::atomic::AtomicUsize;

/// Max number of references that an Arw could have
pub(crate) const MAX_REFCOUNT: usize = isize::MAX as usize;

/// The inner structure that holds the actual data
pub(crate) struct ArwInner<T: Sized> {
    pub(crate) strong: AtomicUsize,
    pub(crate) weak: AtomicUsize,
    marker: PhantomData<T>,
    pub(crate) val: RwLock<T>,
}

impl<T> ArwInner<T> {
    /// Constructs a new `ArwInner` from a concrete value.
    pub(crate) fn new(val: T) -> Self
    where
        T: Any,
    {
        Self {
            val: RwLock::new(val),
            strong: AtomicUsize::new(1),
            weak: AtomicUsize::new(1),
            marker: PhantomData,
        }
    }
}

impl<T: Default> Default for ArwInner<T> {
    fn default() -> Self {
        Self {
            val: RwLock::new(Default::default()),
            strong: AtomicUsize::new(1),
            weak: AtomicUsize::new(1),
            marker: PhantomData,
        }
    }
}