repository·main·Indexed 27 days ago
https://github.com/crossbeam-rs/crossbeamA collection of tools for concurrent programming in Rust, providing high-performance primitives for atomics, data structures, memory management, and thread synchronization. It includes specialized subcrates such as crossbeam-channel for MPMC channels, crossbeam-deque for work-stealing deques, crossbeam-epoch for epoch-based garbage collection, crossbeam-queue for concurrent queues, crossbeam-skiplist for concurrent maps and sets, and crossbeam-utils for synchronization primitives and scoped threads.
crossbeam-channel provides high-performance message passing with the following capabilities:
Senders and Receivers can be cloned and shared among multiple threads.bounded: Channels with a fixed capacity.unbounded: Channels with no fixed capacity.after: Provides a timer-based channel.never: A channel that can never receive a message.tick: Provides a periodic timer channel.select! macro: Allows blocking on multiple channel operations simultaneously.Select struct: Allows selecting over a dynamically built list of channel operations.AtomicCell: A thread-safe mutable memory location. (no_std)AtomicConsume: For reading from primitive atomic types with "consume" ordering. (no_std)Parker: A thread parking primitive.ShardedLock: A sharded reader-writer lock with fast concurrent reads.WaitGroup: For synchronizing the beginning or end of some computation.Backoff: For exponential backoff in spin loops. (no_std)CachePadded: For padding and aligning a value to the length of a cache line. (no_std)scope: For spawning threads that borrow local variables from the stack.Crossbeam provides a suite of tools for concurrent programming, categorized by functionality:
AtomicCell: A thread-safe mutable memory location (supports no_std).AtomicConsume: For reading from primitive atomic types with "consume" ordering (supports no_std).deque: Work-stealing deques for building task schedulers.ArrayQueue: A bounded MPMC (multi-producer multi-consumer) queue with a fixed-capacity buffer (requires alloc).SegQueue: An unbounded MPMC queue that allocates small buffers (segments) on demand (requires alloc).epoch: An epoch-based garbage collector (requires alloc).channel: MPMC channels for message passing.Parker: A thread parking primitive.ShardedLock: A sharded reader-writer lock optimized for fast concurrent reads.WaitGroup: Synchronizes the beginning or end of computations.Backoff: Exponential backoff for spin loops (supports no_std).CachePadded: Pads and aligns values to the length of a cache line (supports no_std).scope: Spawns threads that can safely borrow local variables from the stack.The crossbeam-queue crate provides two types of Multi-Producer Multi-Consumer (MPMC) queues:
ArrayQueue: A bounded queue that allocates a fixed-capacity buffer upon construction.SegQueue: An unbounded queue that allocates small buffers (segments) on demand.Both types can be used in no_std environments if the alloc feature is enabled.
The crossbeam-skiplist crate provides SkipMap and SkipSet. These types offer interfaces similar to BTreeMap and BTreeSet but are designed for safe concurrent access across multiple threads.
For no_std environments that implement alloc, you must enable the alloc feature.
Add crossbeam-deque to your Cargo.toml dependencies to use work-stealing deques in your project. These deques are primarily intended for building task schedulers.
[dependencies]
crossbeam-deque = "0.8"To use Crossbeam in your Rust project, add it to your Cargo.toml dependencies file.
[dependencies]
crossbeam = "0.8"To run the performance benchmarks for crossbeam-channel, use the provided shell script. This will execute the benchmark tests, save the raw results into .txt files, and generate a visualization named plot.png.
./run.shTo use crossbeam-channel in your Rust project, add it to your Cargo.toml dependencies. It is an alternative to std::sync::mpsc providing multi-producer multi-consumer (MPMC) channels with better performance and more features.
[dependencies]
crossbeam-channel = "0.5"To use crossbeam-utils in your project, add it to your Cargo.toml dependencies file.
[dependencies]
crossbeam-utils = "0.8"Add crossbeam-skiplist to your Cargo.toml dependencies to use concurrent SkipMap and SkipSet data structures.
[dependencies]
crossbeam-skiplist = "0.1"