vil_queue 0.4.0

VIL descriptor queue — transport descriptor, bukan payload
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

// =============================================================================
// vil_queue — Descriptor Queue
// =============================================================================
// Queues in VIL transport DESCRIPTORS, not large payloads.
// Payloads live in the shared exchange heap; queues carry only:
// sample_id, origin_port, lineage_id, region_id, and flags.
//
// Implementations:
//   - QueueBackend trait — abstraction allowing swappable implementations
//   - SpscQueue — lock-free SPSC ring buffer (GOLDEN PATH)
//   - DescriptorQueue — lock-free MPMC fallback (debug/general use)
//
// Modules:
//   traits.rs          — QueueBackend trait
//   spsc.rs            — Lock-free SPSC ring buffer (production)
//   descriptor_queue.rs — Lock-free MPMC via SegQueue (fallback/debug)
//
// TASK LIST:
// [x] QueueBackend trait
// [x] DescriptorQueue (SegQueue) — fallback
// [x] SpscRingBuffer<T> — lock-free generic ring buffer
// [x] SpscQueue — Arc-wrapped SPSC for Descriptor
// [x] Cache-line padding (128 byte)
// [x] Power-of-2 capacity + bitmask indexing
// [x] Acquire/Release atomic ordering
// [x] Cross-thread stress tests
// [ ] TODO(future): MPMC bounded queue
// [ ] TODO(future): hybrid wait strategy (spin -> yield -> park)
// =============================================================================

pub mod descriptor_queue;
pub mod spsc;
pub mod traits;

pub use descriptor_queue::DescriptorQueue;
pub use spsc::{SpscQueue, SpscRingBuffer};
pub use traits::QueueBackend;