array_queue.rs |
The implementation is based on Dmitry Vyukov's bounded MPMC queue.
Source:
- <http://www.1024cores.net/home/lock-free-algorithms/queues/bounded-mpmc-queue> |
17027 |
lib.rs |
Concurrent queues.
This crate provides concurrent queues that can be shared among threads:
* [`ArrayQueue`], a bounded MPMC queue that allocates a fixed-capacity buffer on construction.
* [`SegQueue`], an unbounded MPMC queue that allocates small buffers, segments, on demand. |
878 |
seg_queue.rs |
|
18104 |