Skip to content

Commit 84f5c41

Browse files
committed
mpmc: add crossbeam::ArrayQueue implementation
Adds the `crossbeam::ArrayQueue` implementation, modified to use stack-based storage.
1 parent f410958 commit 84f5c41

File tree

3 files changed

+667
-0
lines changed

3 files changed

+667
-0
lines changed

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ ufmt = { version = "0.2", optional = true }
6767
ufmt-write = { version = "0.1", optional = true }
6868
defmt = { version = "1.0.1", optional = true }
6969
zeroize = { version = "1.8", optional = true, default-features = false, features = ["derive"] }
70+
crossbeam-utils = "0.8"
7071

7172
# for the pool module
7273
[target.'cfg(any(target_arch = "arm", target_pointer_width = "32", target_pointer_width = "64"))'.dependencies]

src/mpmc.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,8 @@ use atomic::Ordering;
7979

8080
use crate::storage::{OwnedStorage, Storage, ViewStorage};
8181

82+
pub mod crossbeam_array_queue;
83+
8284
#[cfg(feature = "mpmc_large")]
8385
type AtomicTargetSize = atomic::AtomicUsize;
8486
#[cfg(not(feature = "mpmc_large"))]

0 commit comments

Comments
 (0)