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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
BusyThread.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：2k
源码类别：

模拟服务器

开发平台：

C/C++

BusyThread.cpp：源码内容
  1. // BusyThread.cpp: implementation of the CBusyThread class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "StdAfx.h"
  6. #include "BusyThread.h"
  9. //////////////////////////////////////////////////////////////////////
  10. // Construction/Destruction
  11. //////////////////////////////////////////////////////////////////////
  13. CBusyThread::CBusyThread()
  14. {
  15. m_hStop = NULL;
  16. m_hProcessor = NULL;
  17. }
  19. CBusyThread::~CBusyThread()
  20. {
  21. ASSERT(m_hStop == NULL);
  22. ASSERT(m_hProcessor == NULL);
  23. }
  26. int CBusyThread::IsThreadOK()
  27. {
  28.     return (m_hProcessor != NULL);
  29. }
  32. int CBusyThread::StartThread()
  33. {
  34. int nRet = 0;
  35. if ( NULL != m_hProcessor ) // The thread has been running.
  36. {
  37. return nRet;
  38. }
  39. if (NULL == m_hStop)
  40. {
  41. m_hStop = CreateEvent(NULL, TRUE, FALSE, NULL);
  42. }
  44. DWORD dwThreadID = 0;
  45. m_hProcessor = CreateThread(NULL, 0, CBusyThread::InnerThreadProc, (LPVOID)this, 0, &dwThreadID);
  47. nRet = m_hProcessor != NULL;
  49. return nRet;
  50. }
  52. int CBusyThread::StopThread()
  53. {
  54. int bRet = FALSE;
  56. if (NULL == m_hProcessor
  57. || NULL == m_hStop)
  58. {
  59. bRet = TRUE;
  60. return bRet;
  61. }
  63. SetEvent(m_hStop);
  65. DWORD dwResult = WaitForSingleObject(m_hProcessor, INFINITE);
  66. if (WAIT_FAILED == dwResult)
  67. {
  68. bRet = FALSE;
  69. }
  70. else if (WAIT_OBJECT_0 == dwResult)
  71. {
  72. bRet = TRUE;
  73. }
  74. else if (WAIT_TIMEOUT == dwResult) // Time out.
  75. {
  76. if (TerminateThread(m_hProcessor, 0))
  77. {
  78. bRet = TRUE;
  79. }
  80. else
  81. {
  82. bRet = FALSE;
  83. }
  84. }
  86. if (bRet)
  87. {
  88. CloseHandle(m_hStop);
  89. m_hStop = NULL;
  90. CloseHandle(m_hProcessor);
  91. m_hProcessor = NULL;
  92. }
  94. return bRet;
  95. }
  97. int CBusyThread::PreExecution()
  98. {
  99.     return true;
  100. }
  102. void CBusyThread::PostExecution()
  103. {
  104. }
  106. DWORD WINAPI CBusyThread::InnerThreadProc(LPVOID lpThisParam)
  107. {
  108.     ULONG ulResult = -1;
  109.     
  110.     int nRetCode = false;
  111.     CBusyThread *pThis = (CBusyThread *)lpThisParam;
  112.     
  113.     ASSERT_POINTER(pThis, CBusyThread);
  114.     
  115.     if (NULL == pThis)
  116.         goto Exit0;
  117.     
  118.     nRetCode = pThis->PreExecution();
  119.     if (!nRetCode)
  120.         goto Exit0;
  121.     
  122.     ulResult = pThis->MainExecution();
  123.     pThis->PostExecution();
  124.     
  125. Exit0:
  126.     return ulResult;
  127. }