ZBLOG

实现一个无锁队列demo

以下是一个简单的无锁队列(lock-free queue)的示例代码,使用了原子操作来保证线程安全性。这个示例使用 C++11 的原子操作库。

#include <atomic>
#include <memory>

template<typename T>
class LockFreeQueue {
private:
    struct Node {
        std::shared_ptr<T> data;
        Node* next;

        Node(const T& value) : data(std::make_shared<T>(value)), next(nullptr) {}
    };

    std::atomic<Node*> head;
    std::atomic<Node*> tail;

public:
    LockFreeQueue() : head(new Node(T())), tail(head.load()) {}

    ~LockFreeQueue() {
        while (head != nullptr) {
            Node* temp = head;
            head = temp->next;
            delete temp;
        }
    }

    void enqueue(const T& value) {
        Node* newNode = new Node(value);
        
        // 在尾部插入新节点
        tail.load()->next = newNode;
        tail.store(newNode);
    }

    bool dequeue(T& result) {
        // 如果队列为空,返回false
        if (head.load() == nullptr)
            return false;

        // 从头部删除节点并获取数据
        result = *(head.load()->data);
        
        // 更新头部指针
        Node* oldHead = head.exchange(head.load()->next);

        // 删除旧头部节点
        delete oldHead;
        
        return true;
    }
};

请注意,这只是一个基本示例,可能还需要进行更多的测试和改进以满足实际需求。无锁编程是一项复杂而容易出错的任务,请确保在实际使用时进行充分的测试和验证。


内容由零声教学AI助手提供,问题来源于学员提问

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://golang.0voice.com/?id=16541

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?