async_wait_free_queue.h

Go to the documentation of this file.

 
#ifndef CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_QUEUE_H
#define CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_QUEUE_H
 
#include "logging/record.h"
 
#include <atomic>
#include <cassert>
#include <cstdio>
#include <cstring>
#include <utility>
 
namespace CppLogging {
 
 
template<typename T>
class AsyncWaitFreeQueue
{
public:
 
    explicit AsyncWaitFreeQueue(size_t capacity);
    AsyncWaitFreeQueue(const AsyncWaitFreeQueue&) = delete;
    AsyncWaitFreeQueue(AsyncWaitFreeQueue&&) = delete;
    ~AsyncWaitFreeQueue() { delete[] _buffer; }
 
    AsyncWaitFreeQueue& operator=(const AsyncWaitFreeQueue&) = delete;
    AsyncWaitFreeQueue& operator=(AsyncWaitFreeQueue&&) = delete;
 
    explicit operator bool() const noexcept { return !empty(); }
 
    bool empty() const noexcept { return (size() == 0); }
    size_t capacity() const noexcept { return _capacity; }
    size_t size() const noexcept;
 
 
    bool Enqueue(Record& record);
 
 
    bool Dequeue(Record& record);
 
private:
    struct Node
    {
        std::atomic<size_t> sequence;
        Record value;
    };
 
    typedef char cache_line_pad[128];
 
    cache_line_pad _pad0;
    const size_t _capacity;
    const size_t _mask;
    Node* const _buffer;
 
    cache_line_pad _pad1;
    std::atomic<size_t> _head;
    cache_line_pad _pad2;
    std::atomic<size_t> _tail;
    cache_line_pad _pad3;
};
 
} // namespace CppLogging
 
#include "async_wait_free_queue.inl"
 
#endif // CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_QUEUE_H