www.pudn.com > 0818ThreadPool.rar > ThreadPoolModel.h

 
#if !defined(AFX_ThreadModel_H__E26B0614_AC3A_4C15_9A41_8F10560D79E8__INCLUDED_) 
#define AFX_ThreadModel_H__E26B0614_AC3A_4C15_9A41_8F10560D79E8__INCLUDED_ 
 
//ThreadModel.h: interface for the CThreadModel class. 
//功能描述:该类是线程池模型类该类不能定义任何数据，所以只能从该类派生新类。 
 
 
 
#include "GlobThread.h" 
 
#include "afxwin.h" 
 
#if _MSC_VER > 1000 
#pragma once 
#endif // _MSC_VER > 1000 
 
typedef UINT lpCallBack (LPVOID lpParam); 
typedef void lpCallBack1 (LPVOID lpParam); 
 
enum 
{ 
	SUCCESS_THREADPOOL=1, 
	ERROR_THREAOOL,//其他错误 
	ERROR_ENTRANCE_FALSE,//入口参数错误 
	ERROR_THREADPOOL_FULL,//线程达到最大数量	 
}; 
 
enum//线程退出的一些返回码 
{ 
	SUCCESS_THREAD_RETURN, 
		ERROR_THREAD_RETURN, 
		ERROR_GLOBPOOL_NULL, 
		ERROR_LPPARAM_NULL, 
		ERROR_MULTIPLEEVENT_WAIT 
}; 
 
class CThreadPoolModel   
{ 
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: 
 
	CThreadPoolModel(); 
 
	virtual ~CThreadPoolModel(); 
 
	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(lpCallBack *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;//死亡事件 
}; 
 
#endif // !defined(AFX_THREADDLG_H__E26B0614_AC3A_4C15_9A41_8F10560D79E8__INCLUDED_)