timerqueue.cpp

Socketlib: 一个轻量级的C++ 封装Socket C API 网络编程框架。 它简化了Socket异步事件分派、进程间Socket通信的并发OO网络应用和服务的开发。 目前

//**********************************************************************
//
// Copyright (C) 2005-2007 Zhang bao yuan([e-mail]).
// All rights reserved.
//
// This copy of Socketlib is licensed to you under the terms described 
// in the LICENSE.txt file included in this distribution.
//
//**********************************************************************

#include "../stdafx.h"
#include "timerqueue.h"
namespace SYNC
{

inline CTimerQueue::CTimerQueue(void)
	: m_hTimerQueue(NULL)
{
	Create();
};

inline CTimerQueue::~CTimerQueue(void)
{
	Clear();
};

inline bool CTimerQueue::Clear()
{
	return Release(NULL);
};

inline bool CTimerQueue::Create()
{
	Clear();
	m_hTimerQueue = ::CreateTimerQueue();
	return (m_hTimerQueue != NULL);
};

inline bool CTimerQueue::Release(HANDLE hCompletionEvent)
{
	if (m_hTimerQueue != NULL)
	{
		BOOL bRet = ::DeleteTimerQueueEx(m_hTimerQueue,hCompletionEvent);
		m_hTimerQueue = NULL;
		return bRet;
	};
	return true;
};

//取得句柄
inline HANDLE CTimerQueue::GetHandle() const
{
	return m_hTimerQueue;
};

inline bool CTimerQueue::CreateTimer(PHANDLE phNewTimer,TimerQueueProc timerQueueProc, PVOID pParameter, DWORD nDueTime, DWORD nPeriod, ULONG nFlags)
{
	return ::CreateTimerQueueTimer(phNewTimer,m_hTimerQueue,timerQueueProc,pParameter,nDueTime,nPeriod,nFlags);
};

bool CTimerQueue::DeleteTimer(HANDLE hTimer,HANDLE hCompletionEvent)
{
	return ::DeleteTimerQueueTimer(m_hTimerQueue,hTimer,hCompletionEvent);
};

bool CTimerQueue::UpdateTimer(HANDLE hTimer,ULONG nDueTime,ULONG nPeriod)
{
	return ::ChangeTimerQueueTimer(m_hTimerQueue,hTimer,nDueTime,nPeriod);
};

};