C++无锁数据结构实现示例详解

// 基于自旋锁（或者CAS，原理相同，后者实现较为复杂）
// 通过atomic库中atomic_flag类进行实现自旋达到多生产者多消费者同步。
#include <iostream>
#include <atomic>
class Queue {
    atomic_flag spin_push_flag = false, spin_pop_flag = false;
public:
       void Push() {
        // 自旋+上锁
        while (spin_push_flag.test_and_set())
            ;
        // working...
        // 解锁
        spin_push_flag.clear();
    } 
    void Pop() {
        // 自旋+上锁
        while (spin_pop_flag.test_and_set())
            ;
        // working...
        // 解锁
        spin_pop_flag.clear();
    }
};

// 类似内核kfifo
#include <iostream>
#include <mutex>
class Queue {
private:
    mutex mutex_push, mutex_pop;
public:
       void Push() {
        lock_gurad<mutex> lck(mutex_push);
        // working...
    } 
    void Pop() {
        lock_gurad<mutex> lck(mutex_pop);
        // working...
    }
};