CThread.cpp

[詳解]

//=============================================================================
/// @file
/// スレッドクラス実装ファイル
///
/// スレッドクラス実装ファイルです。
///
/// $Id: CThread.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 <CThread.h>

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

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

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

        // メンバ変数を初期化する
        m_dwThreadId = 0;
    }

    //-------------------------------------------------------------------------
    // リリース関数
    bool CThread::Release() noexcept {
        // 強制終了する
        return Terminate();
    }

    //-------------------------------------------------------------------------
    // 作成関数
    bool CThread::Create( LPTHREAD_START_ROUTINE pfnFunc, LPVOID lpParam ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // 関数アドレスを調べる
            if ( nullptr == pfnFunc ) {
                // 失敗！
                break;
            }
            // スレッドハンドルを調べる
            else if ( nullptr != m_hObject ) {
                // クローズする
                Close();
            }

            // スレッドを作成する
            m_hObject = ::CreateThread( nullptr, 0, pfnFunc, lpParam, 0, nullptr );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }

            // スレッドIDを取得する
            m_dwThreadId = ::GetThreadId( m_hObject );

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

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

    //-------------------------------------------------------------------------
    // オープン関数
    bool CThread::Open( DWORD dwThreadId, DWORD dwAccess ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // スレッドハンドルを調べる
            if ( nullptr != m_hObject ) {
                // クローズする
                Close();
            }

            // スレッドをオープンする
            m_hObject = ::OpenThread( dwAccess, false, dwThreadId );
            if ( nullptr == m_hObject ) {
                // 失敗！
                break;
            }

            // スレッドIDを設定する
            m_dwThreadId = dwThreadId;

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

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

    //-------------------------------------------------------------------------
    // 強制終了関数
    bool CThread::Terminate( DWORD dwExitCode ) noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // スレッドを強制終了する
            if ( 0 == ::TerminateThread( m_hObject, dwExitCode ) ) {
                // 失敗！
                break;
            }

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

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

    //-------------------------------------------------------------------------
    // 終了コード取得関数
    DWORD CThread::GetExitCode() const noexcept {
        // 処理ブロック
        DWORD result = 0;
        do {
            // スレッド終了コードを取得する
            DWORD dwExitCode;
            if ( 0 == ::GetExitCodeThread( m_hObject, &dwExitCode ) ) {
                // 失敗！
                break;
            }

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

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

    //-------------------------------------------------------------------------
    // サスペンド関数
    bool CThread::Suspend() noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // スレッドをサスペンドする
            if ( static_cast< DWORD >( -1 ) == ::SuspendThread( m_hObject ) ) {
                // 失敗！
                break;
            }

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

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

    //-------------------------------------------------------------------------
    // リジューム関数
    bool CThread::Resume() noexcept {
        // 処理ブロック
        bool result = false;
        do {
            // スレッドをリジュームする
            if ( static_cast< DWORD >( -1 ) == ::ResumeThread( m_hObject ) ) {
                // 失敗！
                break;
            }

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

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

#pragma managed( pop )