#wait-free

llq

Wait-free SPSC linked-list queue with individually reusable nodes

1 unstable release

0.1.1 Apr 25, 2021
0.1.0 Apr 25, 2021

#798 in Concurrency

Download history 1225/week @ 2024-06-15 806/week @ 2024-06-22 441/week @ 2024-06-29 381/week @ 2024-07-06 339/week @ 2024-07-13 191/week @ 2024-07-20 272/week @ 2024-07-27 601/week @ 2024-08-03 450/week @ 2024-08-10 211/week @ 2024-08-17 437/week @ 2024-08-24 313/week @ 2024-08-31 703/week @ 2024-09-07 431/week @ 2024-09-14 432/week @ 2024-09-21 309/week @ 2024-09-28

1,960 downloads per month
Used in 6 crates (3 directly)

MIT/Apache

11KB
198 lines

llq

Cargo Documentation

A wait-free single-producer single-consumer linked-list queue with individually reusable nodes.

Queue operations do not block or allocate memory. Individual nodes are allocated and managed separately, and can be reused on multiple queues.

Examples

Using a queue to send values between threads:

use llq::{Node, Queue};

let (mut producer, mut consumer) = Queue::<usize>::new().split();

producer.push(Node::new(0));
producer.push(Node::new(1));
producer.push(Node::new(2));

std::thread::spawn(move || {
    assert_eq!(*consumer.pop().unwrap(), 0);
    assert_eq!(*consumer.pop().unwrap(), 1);
    assert_eq!(*consumer.pop().unwrap(), 2);
    assert!(consumer.pop().is_none());
}).join().unwrap();

Reusing a node between multiple queues:

use llq::{Node, Queue};

let (mut producer1, mut consumer1) = Queue::<usize>::new().split();
let (mut producer2, mut consumer2) = Queue::<usize>::new().split();

let node = Node::new(3);
producer1.push(node);
let node = consumer1.pop().unwrap();
producer2.push(node);
let node = consumer2.pop().unwrap();

assert_eq!(*node, 3);

License

llq is distributed under the terms of both the MIT license and the Apache license, version 2.0. Contributions are accepted under the same terms.

No runtime deps