tokio_rcu 0.2.1

RCU (read-copy-update) for async rust with tokio
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

use std::marker::PhantomData;

/// a phantom type which is not `Send`.
#[derive(Debug, PartialEq, Eq, PartialOrd, Ord, Clone, Copy, Hash)]
pub struct PhantomUnsend {
    phantom: PhantomData<*const ()>,
}
impl PhantomUnsend {
    pub const fn new() -> Self {
        Self {
            phantom: PhantomData,
        }
    }
}
unsafe impl Sync for PhantomUnsend {}

/// a wrapper around a `*mut T` which makes it `Send` and `Sync` if `T` is `Send` and `Sync`.
pub struct PtrMutSendSync<T> {
    ptr: *mut T,
}
impl<T> PtrMutSendSync<T> {
    /// creates a new wrapper around the given pointer.
    ///
    /// # Safety
    ///
    /// any `Send` or `Sync` operation performed on the wrapped pointer must be safe according to the semantics of the underlying
    /// pointer.
    pub unsafe fn new(ptr: *mut T) -> Self {
        Self { ptr }
    }

    /// returns the underlying pointer.
    pub fn ptr(&self) -> *mut T {
        self.ptr
    }
}
unsafe impl<T: Send> Send for PtrMutSendSync<T> {}
unsafe impl<T: Sync> Sync for PtrMutSendSync<T> {}