atb

为Rust实现的一个简单的无锁SPSC 三缓冲。

这种数据结构适用于生产者线程需要定期重建一个较大的数据集并将其发送到实时消费者线程的情况。第三个缓冲区总是对生产者线程可用，因此它永远不需要等待以开始产生新的帧。

示例

const W: usize = 320;
const H: usize = 240;

let pixels = Arc::new(AtomicTripleBuffer::new([0u32; W * H]));

{
    let pixels = pixels.clone();
    std::thread::spawn(move || {
        loop {
            std::thread::sleep(Duration::from_secs_f64(1.0 / 60.0));
            let front = pixels.front_buffer().unwrap();
            // ... display `front` on the screen ...
        }
    });
}

let mut counter = 0u8;
loop {
    let mut bufs = pixels.back_buffers().unwrap();
    let back = bufs.back_mut();
    for y in 0..H {
        let c = counter.wrapping_add(y as u8) as u32;
        let c = c | (c << 8) | (c << 16) | (c << 24);
        for x in 0..W {
            back[y * W + x] = c;
        }
    }
    counter = counter.wrapping_add(1);
    bufs.swap();
    std::thread::sleep(Duration::from_secs_f64(1.0 / 24.0));
}