o3 0.26.0

shared-nothing primitives
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use std::{cell::Cell, mem, ptr};

use crate::depot::{
    array::Index,
    queue::{indexed::lanes, links},
};

pub struct Node<V, const N: usize, S: lanes::raw::State<V> = ()> {
    pub(in crate::depot) lane: Cell<Option<Index<N>>>,
    pub(in crate::depot) hook: links::Hook,
    pub(in crate::depot) value: mem::ManuallyDrop<V>,
    pub(in crate::depot) state: S,
}

impl<V, const N: usize, S: lanes::raw::State<V>> Node<V, N, S> {
    pub(in crate::depot) fn new(index: links::Index, value: lanes::raw::Owned<V, S>) -> Self {
        Self::from_parts(None, links::Hook::new(index), value)
    }

    pub(in crate::depot) fn from_parts(
        lane: Option<Index<N>>,
        hook: links::Hook,
        value: lanes::raw::Owned<V, S>,
    ) -> Self {
        let (value, state) = value.into_parts();
        Self {
            lane: Cell::new(lane),
            hook,
            value: mem::ManuallyDrop::new(value),
            state,
        }
    }

    pub(in crate::depot) fn unpack(
        self,
    ) -> (Option<Index<N>>, links::Hook, lanes::raw::Owned<V, S>) {
        let mut node = mem::ManuallyDrop::new(self);
        // SAFETY: the consumed node owns its exact initialized payload, metadata,
        // and hook. Each non-Copy field moves once and its former Drop is suppressed.
        unsafe {
            let value = mem::ManuallyDrop::take(&mut node.value);
            let hook = ptr::read(&node.hook);
            let lane = node.lane.get();
            (lane, hook, lanes::raw::Owned::from_parts(value, node.state))
        }
    }
}

impl<V, const N: usize, S: lanes::raw::State<V>> Drop for Node<V, N, S> {
    fn drop(&mut self) {
        // SAFETY: each resident node owns its payload and matching destruction
        // state; retirement suppresses this Drop when transferring that ownership.
        unsafe { self.state.clear(&mut self.value) };
    }
}