开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 查看源码
ThreadPoolModel.cpp
资源名称：1731.rar　[点击查看]
上传用户：swkcbjrc
上传日期：2016-04-02
资源大小：45277k
文件大小：3k
源码类别：

游戏

开发平台：

Visual C++

ThreadPoolModel.cpp：源码内容
  1. // ThreaoolModel.cpp: implementation of the CThreadPoolModel class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "ThreadpoolModel.h"
  7. #include "globfunction.h"
  8. #ifdef _DEBUG
  9. #undef THIS_FILE
  10. static char THIS_FILE[]=__FILE__;
  11. #define new DEBUG_NEW
  12. #endif
  14. //////////////////////////////////////////////////////////////////////
  15. // Construction/Destruction
  16. //////////////////////////////////////////////////////////////////////
  18. const DWORD _THREADDEAD_TIMEOUT= 4*1000;// 4秒线程死亡超时
  20. CThreadPoolModel::CThreadPoolModel()
  21. {
  22. InitAll();
  23. }
  26. CThreadPoolModel::~CThreadPoolModel()
  27. {
  28. DeleteAll();
  29. }
  31. //显示当前线程数量
  32. //input: void
  33. //output: 返回线程情况串
  35. CString CThreadPoolModel::ShowThreadInfo(void)
  36. {
  37. CString strShow;
  38. strShow.Format(
  39. "最大线程=%d,当前线程=%d,工作线程=%d,临界线程=%dn",
  40. m_nMaxThreadCount,m_nCurAllThreadCount,
  41. m_nCurWorkThreadCount,m_nCriThreadCount);
  42. return strShow;
  43. }
  45. //初始化所有信息
  46. //input: void
  47. //output: void
  49. void CThreadPoolModel::InitAll(void)
  50. {
  51. InitCriticalSection();
  52. m_nMaxThreadCount=0;
  53. m_nCurAllThreadCount=0;
  54. m_nCurWorkThreadCount=0;
  55. m_nErrorNo=0;
  56. m_hAllDeadEvent=NULL;
  57. m_hMainWnd=NULL;
  58. m_hAllDeadEvent=CreateEvent(NULL,TRUE,FALSE,NULL);
  59. m_nCriThreadCount=0;
  60. }
  62. //删除所有包括句柄
  63. //input: void
  64. //output: void
  66. void CThreadPoolModel::DeleteAll(void)
  67. {
  68. DestroyCriticalSection();
  69. CloseHandle(m_hAllDeadEvent);
  70. }
  72. void CThreadPoolModel::InitCriticalSection(void)
  73. {
  74. ::InitializeCriticalSection(&m_csErrorNo);
  75. }
  78. void CThreadPoolModel::DestroyCriticalSection(void)
  79. {
  80. ::DeleteCriticalSection(&m_csErrorNo);
  81. }
  83. //创建新线程
  84. //input: 线程函数指针，参数指针，线程句柄地址，线程ID地址
  85. //output: TRUE/FASLE
  87. BOOL CThreadPoolModel::CreateNewThread(lpCallBack *pfnThrearoc ,LPVOID pParam,
  88.   HANDLE &hNewThread,
  89.   DWORD &dwThreadId)
  90. {
  91. //如果当前工作线程大于或等于临界线程量，那么我们创建新的线程
  92. if(m_nCurAllThreadCount>=m_nMaxThreadCount)
  93. return FALSE;
  94. if(pfnThrearoc==NULL)
  95. {
  96. TPSetLastError(ERROR_THREADPOOL_FULL);
  97. return FALSE;
  98. }
  99. DWORD dwThreadIdTemp=0;
  100. //创建新线程
  101. hNewThread=chBEGINTHREADEX(NULL,0,pfnThrearoc,pParam,0,&dwThreadIdTemp);
  102. dwThreadId=dwThreadIdTemp;
  103. //增加当前存在线程数量
  104. IncrementCurAllThreadCount();
  105. return TRUE;
  106. }
  108. void CThreadPoolModel::IncrementCurAllThreadCount(void)
  109. {::InterlockedIncrement((LPLONG)&m_nCurAllThreadCount);}
  112. void CThreadPoolModel::DecrementCurAllThreadCount(void)
  113. {::InterlockedDecrement((LPLONG)&m_nCurAllThreadCount);}
  116. void CThreadPoolModel::SetCurAllThreadCount(int nCount)
  117. {::InterlockedExchange((LPLONG)&m_nCurAllThreadCount,nCount);}
  120. void CThreadPoolModel::IncrementCurWorkThreadCount(void)
  121. {
  122. ::InterlockedIncrement((LPLONG)&m_nCurWorkThreadCount);
  123. }
  126. void CThreadPoolModel::DecrementCurWorkThreadCount(void)
  127. {::InterlockedDecrement((LPLONG)&m_nCurWorkThreadCount);}
  130. void CThreadPoolModel::SetCurWorkThreadCount(int nCount)
  131. {::InterlockedExchange((LPLONG)&m_nCurWorkThreadCount,nCount);}
  134. void CThreadPoolModel::IncrementCriThreadCount(void)
  135. {::InterlockedIncrement((LPLONG)&m_nCriThreadCount);}
  138. void CThreadPoolModel::DecrementCriThreadCount(void)
  139. {::InterlockedDecrement((LPLONG)&m_nCriThreadCount);}
  142. void CThreadPoolModel::SetCriThreadCount(int nCount)
  143. {::InterlockedExchange((LPLONG)&m_nCriThreadCount,nCount);}