Unlink

lib.rs:

此软件包提供了一个支持并发 push、pop、peek 和 extend 的无锁栈。

use unlink::Stack;
use std::thread;

let stack = Stack::new();
thread::scope(|s| {
    let stack = &stack;

    s.spawn(move || {
        for i in 0..100 {
            stack.push(i);
        }
    });

    s.spawn(move || {
        for _ in 0..100 {
            stack.pop();
        }
    });

    s.spawn(move || {
        for _ in 0..100 {
            let _ = stack.peek();
        }
    });

    s.spawn(move || {
        for i in 0..10_usize {
            stack.append(vec![i.pow(2), i.pow(3), i.pow(4)].into_iter().collect());
        }
    });
});

stack.into_iter().for_each(|v| print!("{}, ", v));