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
use core::mem::size_of;
pub mod mpmc_linked;
pub mod mpsc_const;
pub mod spsc_const;
#[derive(Debug, PartialEq)]
pub enum QueueError {
Emtpty,
Full,
}
pub trait FiFoQueue<T, const N: usize> {
fn try_push_back(&self, item: T) -> Result<(), QueueError> where T: Copy;
fn try_pop_front(&self) -> Result<T, QueueError> where T: Copy;
fn free(&self) -> usize;
fn capacity(&self) -> usize;
}
pub trait PushRaw {
unsafe fn try_push_back_raw(&self, item: RawItem) -> Result<(), QueueError>;
}
pub unsafe trait SyncProducer { }
pub unsafe trait SyncConsumer { }
#[derive(Copy, Clone)]
pub struct RawItem {
ptr: *const usize,
size: usize,
}
impl RawItem {
pub fn from<T>(item: &T) -> RawItem {
RawItem {
ptr: item as *const _ as *const usize,
size: size_of::<T>(),
}
}
}