CSemaphore.cpp

[詳解]

//=============================================================================
/// @file
/// セマフォクラス実装ファイル
///
/// セマフォクラス実装ファイルです。
///
/// $Id: CSemaphore.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 <CSemaphore.h>

//=============================================================================
// 共通ライブラリ名前空間
namespace LibCommon {
    //=========================================================================
    // セマフォクラス
    //=========================================================================
    // 構築子と解体子
    //-------------------------------------------------------------------------
    // コンストラクタ
    CSemaphore::CSemaphore() noexcept
        // 基底クラスコンストラクタ
        : CSync()
    {}

    //=========================================================================
    // 公開関数
    //-------------------------------------------------------------------------
    // リリース関数
    bool CSemaphore::Release() noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // セマフォカウントを加算する
            long prev;
            result = AddCount( 1, prev );
        } while ( false );

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

    //-------------------------------------------------------------------------
    // 作成関数
    bool CSemaphore::Create( wchar_t const* pszObjectName ) noexcept {
        // 引数を指定して作成する
        return Create( 1, 1, pszObjectName );
    }

    //-------------------------------------------------------------------------
    // 作成関数
    bool CSemaphore::Create( LONG nInitial, LONG nMax, 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 = ::CreateSemaphoreW( nullptr, nInitial, nMax, pszObjectName );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }
            // エラーコードを調べる
            else if ( ERROR_ALREADY_EXISTS != ::GetLastError() ) {
                // 新規作成フラグをセットする
                m_bIsCreate = true;
            }

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

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

    //-------------------------------------------------------------------------
    // オープン関数
    bool CSemaphore::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 = ::OpenSemaphoreW( SEMAPHORE_ALL_ACCESS, false, pszObjectName );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }

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

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

    //-------------------------------------------------------------------------
    // カウント加算関数
    bool CSemaphore::AddCount( long nCount, long& rnPrev ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // セマフォカウントを加算する
            if ( 0 == ::ReleaseSemaphore( m_hObject, nCount, &rnPrev ) ) {
                // 失敗！
                break;
            }

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

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

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

#pragma managed( pop )