c – 使用boost :: atomic的无锁队列 – 我这样做了吗？

我试图从here替换无锁,单生成器,单消费者队列实现中使用的C 11中的std :: atomic.如何用boost::atomic替换它？

长版：

我正试图通过工作线程从我们的应用程序中获得更好的性能.每个线程都有自己的任务队列.我们必须在出列/排队每个任务之前使用锁同步.

然后我找到了Herb Sutter关于无锁队列的文章.这似乎是一个理想的替代品.但代码使用了C 11中的std :: atomic,目前我无法将其引入到项目中.

更多的谷歌搜索导致了一些例子,例如this one for Linux (echelon’s)和this one for Windows (TINESWARE’s).两者都使用平台的特定构造,如WinAPI的InterlockedExchangePointer和GCC的__sync_lock_test_and_set.

我只需要支持Windows& Linux也许我可以逃脱一些#ifdefs.但我认为使用boost :: atomic提供的东西可能更好. Boost Atomic尚未成为官方Boost库的一部分.所以我从http://www.chaoticmind.net/~hcb/projects/boost.atomic/下载了源代码并在我的项目中使用了包含文件.

这是我到目前为止所得到的：

#pragma once

#include <boost/atomic.hpp>

template <typename T>
class LockFreeQueue
{
private:
    struct Node
    {
        Node(T val) : value(val),next(NULL) { }
        T value;
        Node* next;
    };
    Node* first; // for producer only
    boost::atomic<Node*> divider;  // shared
    boost::atomic<Node*> last; // shared

public:
    LockFreeQueue()
    {
        first = new Node(T());
        divider = first;
        last= first;
    }

    ~LockFreeQueue()
    {
        while(first != NULL) // release the list
        {
            Node* tmp = first;
            first = tmp->next;
            delete tmp;
        }
    }

    void Produce(const T& t)
    {
        last.load()->next = new Node(t); // add the new item
        last = last.load()->next;
        while(first != divider) // trim unused nodes
        {
            Node* tmp = first;
            first = first->next;
            delete tmp;
        }
    }

    bool Consume(T& result)
    {
        if(divider != last) // if queue is nonempty
        {
            result = divider.load()->next->value; // C: copy it back
            divider = divider.load()->next;
            return true;  // and report success
        }
        return false;  // else report empty
    }
};

需要注意的一些修改：

boost::atomic<Node*> divider;  // shared
boost::atomic<Node*> last; // shared

和

last.load()->next = new Node(t); // add the new item
    last = last.load()->next;

和

result = divider.load()->next->value; // C: copy it back
        divider = divider.load()->next;

我是否正确地在boost :: atomic中应用了load()(以及隐式store())？我们可以说这相当于Sutter原来的C 11无锁队列吗？

PS.我在SO上研究了许多线程,但似乎没有一个提供boost :: atomic& amp;无锁队列.