servicethread.h

来自「网狐棋牌（家园版）最新版本7.1.1源代码,共享组件源码」· C头文件 代码 · 共 139 行

#ifndef SERVICE_THREAD_HEAD_FILE
#define SERVICE_THREAD_HEAD_FILE

#pragma once

#include "ComService.h"

//////////////////////////////////////////////////////////////////////////
//接口定义

//同步对象接口
interface IThreadLock
{
	//锁定函数
	virtual void Lock()=NULL;
	//解锁函数 
	virtual void UnLock()=NULL;
};

//线程接口
interface IServiceThread
{
	//状态判断
	virtual bool IsRuning()=NULL;
	//启动线程
	virtual bool StartThead()=NULL;
	//停止线程
	virtual bool StopThread(DWORD dwWaitSeconds)=NULL;
	//中止线程
	virtual bool TerminateThread(DWORD dwExitCode)=NULL;
};

//////////////////////////////////////////////////////////////////////////

//临界区同步类
class COM_SERVICE_CLASS CThreadLock : public IThreadLock
{
	//变量定义
private:
	CRITICAL_SECTION					m_csLock;					//临界变量

	//函数定义
public:
	//构造函数
	inline CThreadLock() { ::InitializeCriticalSection(&m_csLock); }
	//析构函数
	inline ~CThreadLock() { ::DeleteCriticalSection(&m_csLock); }

	//功能函数
public:
	//锁定函数
	virtual inline void Lock() { ::EnterCriticalSection(&m_csLock); }
	//解锁函数 
	virtual inline void UnLock() { ::LeaveCriticalSection(&m_csLock); }
};

//////////////////////////////////////////////////////////////////////////

//安全同步锁定句柄
class COM_SERVICE_CLASS CThreadLockHandle
{
	//变量定义
private:
	int								m_nLockCount;				//锁定计数
	IThreadLock						* m_pIThreadLock;			//锁定对象

	//函数定义
public:
	//构造函数
	CThreadLockHandle(IThreadLock * pIThreadLock, bool bAutoLock=true);
	//析构函数
	virtual ~CThreadLockHandle();

	//功能函数
public:
	//锁定函数
	void Lock();
	//解锁函数 
	void UnLock();
	//获取锁定次数
	int inline GetLockCount() { return m_nLockCount; }
};

//////////////////////////////////////////////////////////////////////////

//线程对象类
class COM_SERVICE_CLASS CServiceThread : public IServiceThread
{
	//变量定义
private:
	volatile bool						m_bRun;							//运行标志
	UINT								m_uThreadID;					//线程标识
	HANDLE								m_hThreadHandle;				//线程句柄

	//函数定义
protected:
	//构造函数
	CServiceThread(void);
	//析构函数
	virtual ~CServiceThread(void);

	//接口函数
public:
	//获取状态
	virtual bool IsRuning();
	//启动线程
	virtual bool StartThead();
	//停止线程
	virtual bool StopThread(DWORD dwWaitSeconds=INFINITE);
	//中止线程
	virtual bool TerminateThread(DWORD dwExitCode);

	//功能函数
public:
	//获取标识
	UINT GetThreadID() { return m_uThreadID; }
	//获取句柄
	HANDLE GetThreadHandle() { return m_hThreadHandle; }
	//投递消息
	bool PostThreadMessage(UINT uMessage, WPARAM wParam, LPARAM lParam);

	//事件函数
private:
	//开始事件
	virtual bool OnThreadStratEvent() { return true; }
	//停止事件
	virtual bool OnThreadStopEvent() { return true; }

	//内部函数
private:
	//运行函数
	virtual bool RepetitionRun()=NULL;
	//线程函数
	static unsigned __stdcall ThreadFunction(LPVOID pThreadData);
};

//////////////////////////////////////////////////////////////////////////

#endif