TnbSyncWaitableTimer.h

[詳解]

#pragma once
#include "TnbSync.h"
 
 
 
#if ( _WIN32_WINNT >= 0x0400 ) || ( _WIN32_WINDOWS > 0x0400 )
#else
 #error Reason "This class cannot be used by the target OS."
#endif
 
 
 
//T-TestCaseコードカバレッジDisable
#pragma comment(user,"T-Coverage Disable")
 
 
 
//TNB Library
namespace TNB
{
 
 
 
class CSyncWaitableTimer : public CAbstractSyncHandle, CCopyImpossible
{
    HANDLE  m_hTimer;       
 
public:
 
    explicit CSyncWaitableTimer(bool boIsManualReset = false, LPCTSTR lpszName = NULL)
    {
        m_hTimer = ::CreateWaitableTimer(NULL, boIsManualReset, lpszName);
        ASSERT0(
            m_hTimer != NULL,
            "CSyncWaitableTimer::CSyncWaitableTimer()",
            "WaitableTimerが初期化できませんした。名前に問題がある可能性が有ります。"
        );
        if ( m_hTimer == NULL )
        {
            throw CInvalidParamException();
        }
        ::CancelWaitableTimer(m_hTimer);
    }
 
    explicit CSyncWaitableTimer(HANDLE hTimer)
    {
        VERIFY( m_hTimer = hTimer );
    }
 
    virtual ~CSyncWaitableTimer(void)
    {
        if ( m_hTimer != NULL )
        {
            ::CloseHandle(m_hTimer);
        }
    }
 
    virtual HANDLE GetHandle(void) const
    {
        return m_hTimer;
    }
 
    virtual void Unlock(void) const
    {
        // なにもしない
    }
 
    bool Start(DWORD dwLagTime, DWORD dwInterval)
    {
        if ( m_hTimer != NULL )
        {
            LARGE_INTEGER li;
            li.QuadPart = dwLagTime;
            li.QuadPart *= -10000;
            return !! ::SetWaitableTimer(m_hTimer, &li, dwInterval, NULL, 0, FALSE);
        }
        return false;
    }
 
    void ToLock(void)
    {
        if ( m_hTimer != NULL )
        {
            ::CancelWaitableTimer(m_hTimer);
        }
    }
};
 
 
 
}; // TNB
 
 
 
//T-TestCaseコードカバレッジEnable
#pragma comment(user,"T-Coverage Enable")
 
 
#if 0
static CSyncWaitableTimer s_timer;
 
DWORD WINAPI DoThread(DWORD ThreadCount)
{
    for (int i=0;i<5;i++) 
    {
        EXCLUSIVE(&s_timer);
        TRACE1("スレッド%d: 処理開始\n", ThreadCount);
        Sleep(400*ThreadCount);
        TRACE1("スレッド%d: 処理終了\n", ThreadCount);
    }
    return 0;
}
 
void ____wt() 
{
    HANDLE hThread[2];
    DWORD ThreadID[2];
    /* スレッドを2つ作成 */
    for (int i=0; i<2; i++) 
    {
        hThread[i] = CreateThread(
                    NULL, 0, (LPTHREAD_START_ROUTINE)DoThread,
                    (LPVOID)i,0,&ThreadID[i]);
    }
    TRACE0("開始\n");
    s_timer.Start(1000,1000);
    WaitForMultipleObjects(2, hThread, TRUE, INFINITE);// スレッドの終了まで待機
    CloseHandle(hThread[0]);
    CloseHandle(hThread[1]);
 
    typedef LONG (WINAPI *P_InterlockedCompareExchange)(LONG*,LONG,LONG);
    typedef HANDLE (WINAPI *P_IcmpCreateFile)(VOID);
    HANDLE h = CDynamicFuncT<P_IcmpCreateFile>("ICMP.dll","IcmpCreateFile")()();
 
    CDynamicFuncT<P_InterlockedCompareExchange> func1("kernel32.dll","InterlockedCompareExchange");
    LONG l1 = 0;
    LONG l2 = func1()(&l1,1,0);
}
#endif