nblf-queue 0.1.0

Atomic, wait-free MPMC queues based on the nblfq algorithm
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

use alloc::boxed::Box;

use crate::core::buffer::Buffer;

pub(crate) struct BoxedBuffer<S> {
    inner: Box<[S]>,
}

impl<S: Default> BoxedBuffer<S> {
    pub(crate) fn new(size: usize) -> Self {
        Self {
            inner: (0..size).map(|_| S::default()).collect(),
        }
    }
}

impl<S> Buffer for BoxedBuffer<S> {
    type Slot = S;

    fn capacity(&self) -> usize {
        self.inner.len()
    }

    fn inner(&self) -> &[Self::Slot] {
        &self.inner
    }
}