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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
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 "KStdAfx.h"
  10. #include "GlobalFun.h"
  11. #include "KThread.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 = KPICreateEvent(NULL, TRUE, FALSE, NULL);
  35. }
  37. m_hProcessor = KPICreateThread(KThread::ThreadFun, (LPVOID)this, NULL);
  39. hRet = m_hProcessor;
  41. return hRet;
  42. }
  44. BOOL KThread::Stop()
  45. {
  46. BOOL bRet = FALSE;
  48. if (NULL == m_hProcessor
  49. || NULL == m_hStop)
  50. {
  51. bRet = TRUE;
  52. return bRet;
  53. }
  55. KPISetEvent(m_hStop);
  57. DWORD dwResult = KPIWaitForSingleObject(m_hProcessor, INFINITE);
  58. if (0 == dwResult)
  59. {
  60. bRet = FALSE;
  61. }
  62. else if (1 == dwResult)
  63. {
  64. bRet = TRUE;
  65. }
  66. else if (2 == dwResult) // Time out.
  67. {
  68. if (KPITerminateThread(m_hProcessor, 0))
  69. {
  70. bRet = TRUE;
  71. }
  72. else
  73. {
  74. bRet = FALSE;
  75. }
  76. }
  78. if (bRet)
  79. {
  80. KPICloseHandle(m_hStop);
  81. m_hStop = NULL;
  82. KPICloseHandle(m_hProcessor);
  83. m_hProcessor = NULL;
  84. }
  86. return bRet;
  87. }
  89. DWORD WINAPI KThread::ThreadFun(LPVOID lpParam)
  90. {
  91. assert(lpParam);
  92. KThread* pThis = (KThread*)lpParam;
  93. return pThis->Main(lpParam);
  94. }
  96. K_CS::K_CS()
  97. {
  98. ::InitializeCriticalSection(&m_sect);
  100. m_bAcquired = FALSE;
  101. }
  103. K_CS::~K_CS()
  104. {
  105. Unlock();
  107. ::DeleteCriticalSection(&m_sect);
  108. }
  110. BOOL K_CS::Lock()
  111. {
  112. ::EnterCriticalSection(&m_sect);
  113. m_bAcquired = TRUE;
  114. return m_bAcquired;
  115. }
  117. BOOL K_CS::Unlock()
  118. {
  119. if (m_bAcquired)
  120. {
  121. ::LeaveCriticalSection(&m_sect);
  122. m_bAcquired = FALSE;
  123. }
  125. // successfully unlocking means it isn't acquired
  126. return !m_bAcquired;
  127. }