threadpoolmodel.h

vc网络游戏设计与实现源代码

//ThreadModel.h: interface for the CThreadModel class.
//功能描述:该类是线程池模型类该类不能定义任何数据，所以只能从该类派生新类。




#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000


enum
{
	SUCCESS_THREAOOL=1,
	ERROR_THREAOOL,//其他错误
	ERROR_ENTRANCE_FALSE,//入口参数错误
	ERROR_THREAOOL_FULL,//线程达到最大数量	
};

enum//线程退出的一些返回码
{
	SUCCESS_THREAD_RETURN,
	ERROR_THREAD_RETURN,
	ERROR_GLOBPOOL_NULL,
	ERROR_LPPARAM_NULL,
	ERROR_MULTIPLEEVENT_WAIT
};


const DWORD _THREADDEAD_TIMEOUT= 4*1000;// 4秒线程死亡超时

class CThreaoolModel  
{
private:
	
	void InitAll(void);
	
	void DeleteAll(void);
	//
	void InitCriticalSection(void);

	void DestroyCriticalSection(void);

	void inline TPSetLastError(int nErrorNo)
	{
		::EnterCriticalSection(&m_csErrorNo);
		m_nErrorNo=nErrorNo;
		::LeaveCriticalSection(&m_csErrorNo);
	};

public:

	CThreaoolModel();

	virtual ~CThreaoolModel();

	void SetCriThreadCount(int nCount);

	int inline GetCriThreadCount(void)
	{return (int)m_nCriThreadCount;};

	int GetMaxThreadCount(void)
	{return (int)m_nMaxThreadCount;};

	int inline GetCurAllThreadCount(void)
	{return (int)m_nCurAllThreadCount;};

protected:

	virtual CString ShowThreadInfo(void);

	BOOL CreateNewThread(AFX_THREAROC pfnThrearoc,LPVOID pParam,
			HANDLE &hNewThread,DWORD &dwThreadId);

	void inline SetMaxThreadCount(int nMaxThreadCount)
	{m_nMaxThreadCount=nMaxThreadCount;};

	int inline GetCurWorkThreadCount(void)
	{return (int)m_nCurWorkThreadCount;};
	void inline SetMainWnd(HWND hMainWnd)
	{m_hMainWnd=hMainWnd;};

	HWND inline GetMainWnd(void)
	{return m_hMainWnd;};
protected:

	void IncrementCurAllThreadCount(void);

	void DecrementCurAllThreadCount(void);

	void SetCurAllThreadCount(int nCount);


	void IncrementCurWorkThreadCount(void);

	void DecrementCurWorkThreadCount(void);

	void SetCurWorkThreadCount(int nCount);


	void IncrementCriThreadCount(void);

	void DecrementCriThreadCount(void);


	int inline TPGetLastError(void)
	{return (m_nErrorNo);};
private:

	int m_nErrorNo;//错误号码

	CRITICAL_SECTION m_csErrorNo;

	LONG m_nMaxThreadCount;//允许线程最大数量

	LONG m_nCurAllThreadCount;//当前存在的线程数量

	LONG m_nCurWorkThreadCount;//当前工作的线程数量

	LONG m_nCriThreadCount;//临界线程量

	HWND m_hMainWnd;//主窗口句柄
protected:

	HANDLE m_hAllDeadEvent;//死亡事件
};