ConsumerEntry.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorBarrier.h"
 
namespace catapult { namespace disruptor {
 
    class ConsumerEntry {
    public:
        explicit ConsumerEntry(size_t level)
                : m_level(level)
                , m_position(0)
        {}
 
        PositionType advance() {
            return ++m_position;
        }
 
    public:
        PositionType position() const {
            return m_position;
        }
 
        size_t level() const {
            return m_level;
        }
 
    private:
        const size_t m_level;
        PositionType m_position;
    };
}}