TnbSyncMetered.h

[詳解]

#pragma once
#include "TnbSync.h"
 
 
 
//T-TestCaseコードカバレッジDisable
#pragma comment(user,"T-Coverage Disable")
 
 
 
//TNB Library
namespace TNB
{
 
 
 
#ifndef _TnbDOXYGEN //Document作成用シンボル
    namespace NMetered
    {
        //Mr.Dan Chou の排他Obj
        #include "other/MeteredSection.h"
    };
#endif
 
 
 
class CSyncMetered : public ISynchronized, CCopyImpossible
{
    NMetered::LPMETERED_SECTION m_pms;      
    mutable LONG    m_lLockCount;           
public:
 
    explicit CSyncMetered(LPCTSTR lpszName = NULL, int iMaximumCount = 1)
    {
        ASSERTLIB( lpszName == NULL || STRLIB::GetLen(lpszName) < MAX_METSECT_NAMELEN );
        m_pms = NMetered::CreateMeteredSection(iMaximumCount, iMaximumCount, lpszName);
        m_lLockCount = 0;
        ASSERT0(
            m_pms != NULL,
            "CSyncMetered::CSyncMetered()",
            "MeteredSectionが初期化できませんした。名前に問題がある可能性が有ります。"
        );
        if ( m_pms == NULL )
        {
            throw CInvalidParamException();
        }
    }
 
    virtual ~CSyncMetered(void)
    {
        if ( m_pms != NULL )
        {
            if ( m_lLockCount > 0 )
            {
                NMetered::LeaveMeteredSection(m_pms, m_lLockCount, NULL);
            }
            NMetered::CloseMeteredSection(m_pms);
            m_pms = NULL;
        }
    }
 
    virtual bool Lock(DWORD dwTime = INFINITE) const
    {
        if ( m_pms != NULL )
        {
            DWORD dwRc = NMetered::EnterMeteredSection(m_pms, dwTime);
            if ( dwRc == WAIT_OBJECT_0 )
            {
                ::InterlockedIncrement(&m_lLockCount);
                return true;
            }
        }
        return false;
    }
 
    virtual void Unlock(void) const
    {
        if ( m_pms != NULL && m_lLockCount > 0 )
        {
            NMetered::LeaveMeteredSection(m_pms, 1, NULL);
            ::InterlockedDecrement(&m_lLockCount);
        }
    }
};
 
 
 
}; // TNB
 
 
 
//T-TestCaseコードカバレッジEnable
#pragma comment(user,"T-Coverage Enable")