CMutex.cpp

[詳解]

//=============================================================================
/// @file
/// ミューテックスクラス実装ファイル
///
/// ミューテックスクラス実装ファイルです。
///
/// $Id: CMutex.cpp 245 2019-03-20 15:03:41Z admin $
/// $Date: 2019-03-21 00:03:41 +0900 (2019/03/21 (木)) $
/// $Author: admin $
///
/// @attention なし

#pragma managed( push, off )

//=============================================================================
// インクルードファイル
#include <CMutex.h>
#include <LibUtility.h>

//=============================================================================
// 共通ライブラリ名前空間
namespace LibCommon {
    //=========================================================================
    // ミューテックスクラス
    //=========================================================================
    // 構築子と解体子
    //-------------------------------------------------------------------------
    // コンストラクタ
    CMutex::CMutex() noexcept
        // 基底クラスコンストラクタ
        : CSync()
        // メンバ変数初期化
        , m_dwLockCount( 0 )
    {}

    //-------------------------------------------------------------------------
    // デストラクタ
    CMutex::~CMutex() noexcept {
        // クローズする
        Close();
    }

    //=========================================================================
    // 公開関数
    //-------------------------------------------------------------------------
    // クローズ関数
    void CMutex::Close() noexcept {
        // 基底クラスの関数を実行する
        CSync::Close();

        // メンバ変数をクリアする
        m_dwLockCount = 0;
    }

    //-------------------------------------------------------------------------
    // リリース関数
    bool CMutex::Release() noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // ミューテックス所有権を解放する
            if ( 0 == ::ReleaseMutex( m_hObject ) ) {
                // 致命的エラー！
                NotifyFatalError();
                break;
            }

            // 成功！
            result = true;
        } while ( false );

        // 実行結果を返す
        return result;
    }

    //-------------------------------------------------------------------------
    // ロック関数
    bool CMutex::Lock( DWORD dwTime ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // ロックカウントを調べる
            if ( UINT_MAX == m_dwLockCount ) {
                // 致命的エラー！
                NotifyFatalError();
                break;
            }
            // ウェイトする
            else if ( !Wait( dwTime ) ) {
                // 待機時間を調べる
                if ( INFINITE == dwTime ) {
                    // 致命的エラー！
                    NotifyFatalError();
                }

                // 失敗！
                break;
            }

            // ロックカウントをインクリメントする
            ++m_dwLockCount;

            // 成功！
            result = true;
        } while ( false );

        // 実行結果を返す
        return result;
    }

    //-------------------------------------------------------------------------
    // ロック解除関数
    bool CMutex::Unlock() noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // ロックカウントを調べる
            if ( 0 == m_dwLockCount ) {
                // 致命的エラー！
                NotifyFatalError();
                break;
            }
            // リリースする
            else if ( 0 == ::ReleaseMutex( m_hObject ) ) {
                // 致命的エラー！
                NotifyFatalError();
                break;
            }

            // ロックカウントをデクリメントする
            --m_dwLockCount;

            // 成功！
            result = true;
        } while ( false );

        // 実行結果を返す
        return result;
    }

    //-------------------------------------------------------------------------
    // 作成関数
    bool CMutex::Create( wchar_t const* pszObjectName ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // オブジェクトハンドルを調べる
            if ( nullptr != m_hObject ) {
                // クローズする
                Close();
            }

            // オブジェクト名を調べる
            wchar_t szBuffer[ MAX_PATH ];
            if ( nullptr != pszObjectName ) {
                // オブジェクト名に拡張子を追加する
                ::wcscpy_s( szBuffer, pszObjectName );
                ::wcscat_s( szBuffer, OBJECT_NAME_EXT );
                pszObjectName = szBuffer;
            }

            // ミューテックスを作成する
            m_hObject = ::CreateMutexW( nullptr, false, pszObjectName );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }
            // エラーコードを調べる
            else if ( ERROR_ALREADY_EXISTS != ::GetLastError() ) {
                // 新規作成フラグをセットする
                m_bIsCreate = true;
            }

            // 成功！
            result = true;
        } while ( false );

        // 実行結果を返す
        return result;
    }

    //-------------------------------------------------------------------------
    // オープン関数
    bool CMutex::Open( wchar_t const* pszObjectName ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // オブジェクト名を調べる
            if ( nullptr == pszObjectName ) {
                // 失敗！
                break;
            }
            // オブジェクトハンドルを調べる
            else if ( nullptr != m_hObject ) {
                // クローズする
                Close();
            }

            // オブジェクト名に拡張子を追加する
            wchar_t szBuffer[ MAX_PATH ];
            ::wcscpy_s( szBuffer, pszObjectName );
            ::wcscat_s( szBuffer, OBJECT_NAME_EXT );
            pszObjectName = szBuffer;

            // ミューテックスをオープンする
            m_hObject = ::OpenMutexW( MUTEX_ALL_ACCESS, false, pszObjectName );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }

            // 成功！
            result = true;
        } while ( false );

        // 実行結果を返す
        return result;
    }

    //=====================================================================
    // 静的限定公開文字列定数
    wchar_t const* const CMutex::OBJECT_NAME_EXT = L".CMutex";
}

#pragma managed( pop )