DisruptorBarriers.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorBarrier.h"
#include <boost/thread.hpp>
#include <vector>
#include <stdint.h>
 
namespace catapult { namespace disruptor {
 
    class DisruptorBarriers {
    public:
        explicit DisruptorBarriers(size_t levelsCount);
 
    public:
        inline size_t size() const {
            return m_barriers.size();
        }
 
        inline const DisruptorBarrier& operator[](size_t level) const {
            return *m_barriers[level];
        }
 
        inline DisruptorBarrier& operator[](size_t level) {
            return *m_barriers[level];
        }
 
    private:
        std::vector<std::unique_ptr<DisruptorBarrier>> m_barriers;
    };
}}