orx-concurrent-vec 3.10.0

A thread-safe, efficient and lock-free vector allowing concurrent grow, read and update operations.
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

use crate::{ConcurrentVec, elem::ConcurrentElement};
use core::sync::atomic::AtomicUsize;
use orx_concurrent_option::{MutHandle, StateU8};
use orx_pinned_vec::IntoConcurrentPinnedVec;
use orx_split_vec::{Doubling, SplitVec};

pub(crate) type DefaultPinVec<T> = SplitVec<ConcurrentElement<T>, Doubling>;

impl<T, P> ConcurrentVec<T, P>
where
    P: IntoConcurrentPinnedVec<ConcurrentElement<T>>,
{
    #[inline(always)]
    pub(crate) fn len_reserved(&self) -> &AtomicUsize {
        &self.core.state().len_reserved
    }

    #[inline(always)]
    pub(crate) fn len_written(&self) -> &AtomicUsize {
        &self.core.state().len_written
    }

    #[inline(always)]
    pub(crate) unsafe fn mut_handle(
        &self,
        i: usize,
        initial_state: StateU8,
        success_state: StateU8,
    ) -> Option<MutHandle<'_, T>> {
        match i < self.len() {
            true => unsafe {
                self.core
                    .get(i)
                    .and_then(|e| e.0.mut_handle(initial_state, success_state))
            },
            false => None,
        }
    }
}