DisruptorBarrier.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorTypes.h"
#include "catapult/utils/Logging.h"
#include <atomic>
#include <stddef.h>
#include <stdint.h>
 
namespace catapult { namespace disruptor {
 
    class DisruptorBarrier {
    public:
        DisruptorBarrier(size_t level, PositionType position)
                : m_level(level)
                , m_position(position)
        {}
 
        inline void advance() {
            ++m_position;
        }
 
        inline size_t level() const {
            return m_level;
        }
 
        inline PositionType position() const {
            return m_position;
        }
 
    private:
        const size_t m_level;
        std::atomic<PositionType> m_position;
    };
}}