mpsc_linked_queue.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_MPSC_LINKED_QUEUE_H
#define CPPCOMMON_THREADS_MPSC_LINKED_QUEUE_H
 
#include <atomic>
#include <cstring>
#include <utility>
 
namespace CppCommon {
 
 
template<typename T>
class MPSCLinkedQueue
{
public:
    MPSCLinkedQueue();
    MPSCLinkedQueue(const MPSCLinkedQueue&) = delete;
    MPSCLinkedQueue(MPSCLinkedQueue&&) = delete;
    ~MPSCLinkedQueue();
 
    MPSCLinkedQueue& operator=(const MPSCLinkedQueue&) = delete;
    MPSCLinkedQueue& operator=(MPSCLinkedQueue&&) = delete;
 
 
    bool Enqueue(const T& item);
 
    bool Enqueue(T&& item);
 
 
    bool Dequeue(T& item);
 
private:
    struct Node
    {
        std::atomic<Node*> next;
        T value;
    };
 
    typedef char cache_line_pad[128];
 
    cache_line_pad _pad0;
    std::atomic<Node*> _head;
    cache_line_pad _pad1;
    std::atomic<Node*> _tail;
    cache_line_pad _pad2;
};
 
} // namespace CppCommon
 
#include "mpsc_linked_queue.inl"
 
#endif // CPPCOMMON_THREADS_MPSC_LINKED_QUEUE_H