Crossbeam for advanced concurrent data structures

14762 views

                  use crossbeam::channel::unbounded;
use std::thread;

fn main() {
    let (tx, rx) = unbounded();

    thread::spawn(move || {
        tx.send("message").unwrap();
    });

    let msg = rx.recv().unwrap();
    println!("Received: {}", msg);
}

Crossbeam provides lock-free data structures and utilities for concurrent programming. The crossbeam-channel crate offers multi-producer multi-consumer channels with better performance than std::sync::mpsc. crossbeam-utils has scoped threads (borrow data without 'static). crossbeam-epoch enables lock-free memory reclamation. I use crossbeam when the standard library's concurrency primitives aren't enough: MPMC channels, work stealing, or lock-free algorithms. The scoped threads are especially handy for parallelizing work that borrows local data. Crossbeam is battle-tested and used in high-performance systems. It's the next step after mastering std::sync.

Marcus Chen

More from Marcus Chen

Crossbeam for advanced concurrent data structures

0 Comments

More from Marcus Chen