TnbParSecondCounter.h

[詳解]

#pragma once
#include "TnbSync.h"
#include "TnbTickCount.h"
 
 
 
//TNB Library
namespace TNB
{
 
 
 
class CParSecondCounter : CCopyImpossible
{
public:
 
    CParSecondCounter(size_t second = 5)
    {
        Initialize(second);
    }
 
    void Initialize(size_t second = 5)
    {
        if ( second < 1 )
        {
            second = 1;
        }
        m_postCounts.Resize(second + 1);
        m_postCounts[0] = 0;
        m_validCount = 0;
        m_newestIndex = 0;
        m_nowTickSecond = 0;
        m_maxPostCount = 0;
        m_tick.Reset();
    }
 
    void Post(DWORD c = 1)
    {
        EXCLUSIVE(&m_sync);
        DWORD t = m_tick.GetPassedCount() / 1000;
        if ( m_nowTickSecond == t )
        {
            m_postCounts[m_newestIndex] += c;
            return;
        }
        m_nowTickSecond = t;
        size_t count = m_postCounts.GetSize();
        if ( m_validCount < count )
        {
            m_validCount++;
        }
        if ( m_postCounts[m_newestIndex] > m_maxPostCount )
        {
            m_maxPostCount = m_postCounts[m_newestIndex];
        }
        m_newestIndex = (m_newestIndex + 1) % count;
        m_postCounts[m_newestIndex] = c;
    }
 
    double GetAverage(void) const
    {
        EXCLUSIVE(&m_sync);
        if ( m_validCount > 1 )
        {
            size_t count = m_postCounts.GetSize();
            DWORD r = 0;
            loop ( i, m_validCount - 1 )
            {
                r += m_postCounts[(count + count + m_newestIndex - i - 1) % count];
            }
            double a = r;
            return a / (m_validCount - 1);
        }
        return 0;
    }
 
    DWORD GetMax(void) const
    {
        return m_maxPostCount;
    }
 
private:
    CWorkMemT<DWORD>    m_postCounts;       
    DWORD               m_validCount;       
    DWORD               m_newestIndex;      
    DWORD               m_nowTickSecond;    
    DWORD               m_maxPostCount;     
    CTickCount          m_tick;             
    CSyncSection        m_sync;
};
 
 
 
};