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

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

模拟服务器

开发平台：

C/C++

KThread.cpp：源码内容
  1. // -------------------------------------------------------------------------
  2. // 文件名 ： KThread.cpp
  3. // 创建者 ： 万里
  4. // 创建时间 ： 2003-5-1 21:15:58
  5. // 功能描述 ：
  6. //
  7. // -------------------------------------------------------------------------
  9. #include "StdAfx.h"
  10. #include "KThread.h"
  11. #include "process.h"
  13. KThread::KThread()
  14. {
  15. m_hStop = NULL;
  16. m_hProcessor = NULL;
  17. }
  19. KThread::~KThread()
  20. {
  21. assert(m_hStop == NULL);
  22. assert(m_hProcessor == NULL);
  23. }
  25. HANDLE KThread::Start()
  26. {
  27. HANDLE hRet = NULL;
  28. if ( NULL != m_hProcessor ) // The thread has been running.
  29. {
  30. return hRet;
  31. }
  32. if (NULL == m_hStop)
  33. {
  34. m_hStop = CreateEvent(NULL, TRUE, FALSE, NULL);
  35. }
  37. unsigned ID = 0;
  38. m_hProcessor = (HANDLE)_beginthreadex( NULL, 0, KThread::ThreadFun, (void *)this, 0, &ID );
  40. hRet = m_hProcessor;
  42. return hRet;
  43. }
  45. BOOL KThread::Stop()
  46. {
  47. BOOL bRet = FALSE;
  49. if (NULL == m_hProcessor
  50. || NULL == m_hStop)
  51. {
  52. bRet = TRUE;
  53. return bRet;
  54. }
  56. SetEvent(m_hStop);
  58. DWORD dwResult = WaitForSingleObject(m_hProcessor, INFINITE);
  59. if (WAIT_FAILED == dwResult)
  60. {
  61. bRet = FALSE;
  62. }
  63. else if (WAIT_OBJECT_0 == dwResult)
  64. {
  65. bRet = TRUE;
  66. }
  67. else if (WAIT_TIMEOUT == dwResult) // Time out.
  68. {
  69. if (TerminateThread(m_hProcessor, 0))
  70. {
  71. bRet = TRUE;
  72. }
  73. else
  74. {
  75. bRet = FALSE;
  76. }
  77. }
  79. if (bRet)
  80. {
  81. CloseHandle(m_hStop);
  82. m_hStop = NULL;
  83. CloseHandle(m_hProcessor);
  84. m_hProcessor = NULL;
  85. }
  87. return bRet;
  88. }
  90. BOOL KThread::IsAskingStop()
  91. {
  92. assert(m_hStop);
  93. return ::WaitForSingleObject(m_hStop, 0) != WAIT_TIMEOUT;
  94. }
  97. unsigned  __stdcall KThread::ThreadFun( void * lpParam )
  98. {
  99. try
  100. {
  101. KThread* pThis = (KThread*)lpParam;
  102. assert(pThis);
  104. try
  105. {
  106. if (!pThis)
  107. throw -1;
  108. return pThis->Main(lpParam);
  109. }
  110. catch (...)
  111. {//try Clearup
  112. if (NULL != pThis->m_hProcessor)
  113. {
  114. ::CloseHandle(pThis->m_hProcessor);
  115. pThis->m_hProcessor = NULL;
  116. }
  117. if (NULL != pThis->m_hStop)
  118. {
  119. ::CloseHandle(pThis->m_hStop);
  120. pThis->m_hStop = NULL;
  121. }
  123. return -1;
  124. }
  125. }
  126. catch (...)
  127. {//fatal
  128. return -1;
  129. }
  130. }