PRMasterHistory.hpp

#pragma once
#include <samchon/API.hpp>

#include <samchon/protocol/master/PRInvokeHistory.hpp>

#include <atomic>
#include <vector>
#include <samchon/library/CriticalVector.hpp>

namespace samchon
{
namespace protocol
{
namespace master
{
    class ParallelSystemArray;
    class PRMasterHistoryArray;

    class SAMCHON_FRAMEWORK_API PRMasterHistory
        : public PRInvokeHistory
    {
        friend class ParallelSystemArray;

    protected:
        typedef PRInvokeHistory super;

        ParallelSystemArray *master;

        library::CriticalVector<PRInvokeHistory*> historyArray;

        std::atomic<size_t> completed;

    public:
        PRMasterHistory(PRMasterHistoryArray*, std::shared_ptr<Invoke>, size_t, size_t);
        virtual ~PRMasterHistory() = default;

        virtual void notifyEnd() override;
    };
};
};
};