snaplock 0.0.1

RwLock with wait-free Reads and sequential Writes
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

use std::cell::{RefCell, RefMut};
use std::sync::Arc;

#[derive(Clone)]
pub struct CloneCell<T> {
    inner: Arc<RefCell<T>>,
}

impl<T> CloneCell<T> {
    pub fn new(val: T) -> Self {
        Self {
            inner: Arc::new(RefCell::new(val)),
        }
    }
}

impl<T: Clone> CloneCell<T> {
    pub fn get(&self) -> T {
        self.inner.borrow().clone()
    }

    pub fn set(&self, value: T) {
        let mut borrowed: Result<RefMut<T>, _> = self.inner.try_borrow_mut();

        while borrowed.is_err() {
            borrowed = self.inner.try_borrow_mut()
        }

        *borrowed.unwrap() = value;
    }
}