multiqueue 0.3.2

A fast mpmc broadcast queue
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


use std::sync::atomic::Ordering;
// I'm aware of silly issues with dependency tracking and things like
// f = load_consume(...); *a[f - f]; that isn't actually consume
// This project uses it exclusively for things like b = *a, c = *b

#[cfg(any(target_arch = "x64",
          target_arch = "x64_64",
          target_arch = "aarch64",
          target_arch = "arm"))]
mod can_consume {
    use std::sync::atomic::Ordering;
    pub const CONSUME: Ordering = Ordering::Relaxed;
}

#[cfg(not(any(target_arch = "x64",
              target_arch = "x64_64",
              target_arch = "aarch64",
              target_arch = "arm")))]
mod can_consume {
    use std::sync::atomic::Ordering;
    pub const CONSUME: Ordering = Ordering::Acquire;
}

pub const CONSUME: Ordering = can_consume::CONSUME;