mpsc_linked_batcher.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_MPSC_LINKED_BATCHER_H
#define CPPCOMMON_THREADS_MPSC_LINKED_BATCHER_H
 
#include <atomic>
#include <cassert>
#include <functional>
#include <utility>
 
namespace CppCommon {
 
 
template<typename T>
class MPSCLinkedBatcher
{
public:
    MPSCLinkedBatcher();
    MPSCLinkedBatcher(const MPSCLinkedBatcher&) = delete;
    MPSCLinkedBatcher(MPSCLinkedBatcher&&) = delete;
    ~MPSCLinkedBatcher();
 
    MPSCLinkedBatcher& operator=(const MPSCLinkedBatcher&) = delete;
    MPSCLinkedBatcher& operator=(MPSCLinkedBatcher&&) = delete;
 
 
    bool Enqueue(const T& item);
 
    bool Enqueue(T&& item);
 
 
    bool Dequeue(const std::function<void(const T&)>& handler = [](const int&){});
 
private:
    struct Node
    {
        Node* next;
        T value;
    };
 
    std::atomic<Node*> _head;
};
 
} // namespace CppCommon
 
#include "mpsc_linked_batcher.inl"
 
#endif // CPPCOMMON_THREADS_MPSC_LINKED_BATCHER_H