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

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

模拟服务器

开发平台：

C/C++

KThread.cpp：源码内容
  1. //---------------------------------------------------------------------------
  2. // Sword3 Engine (c) 1999-2000 by Kingsoft
  3. //
  4. // File: KThread.cpp
  5. // Date: 2000.08.08
  6. // Code: WangWei(Daphnis)
  7. // Desc: BG2132 Font Class
  8. //---------------------------------------------------------------------------
  9. #include "KWin32.h"
  10. #include "KDebug.h"
  11. #include "KMemBase.h"
  12. #include "KThread.h"
  13. #ifdef WIN32
  14. #include "process.h"
  15. #endif
  17. KThread::KThread()
  18. {
  19. #ifdef WIN32
  20. m_ThreadHandle = NULL;
  21. m_ThreadId = 0;
  22. m_ThreadFunc = NULL;
  23. m_ThreadParam = NULL;
  24. #endif
  25. }
  26. //---------------------------------------------------------------------------
  27. // 函数: ~KThread
  28. // 功能: 析购函数
  29. // 参数: void
  30. // 返回: void
  31. //---------------------------------------------------------------------------
  32. KThread::~KThread()
  33. {
  34. #ifdef WIN32
  35. if (m_ThreadHandle)
  36. {
  37. CloseHandle(m_ThreadHandle);
  38. m_ThreadHandle = NULL;
  39. }
  40. #else
  42. #endif
  43. }
  44. //---------------------------------------------------------------------------
  45. // 函数: MyThreadProc
  46. // 功能: 线程过程
  47. // 参数: lpParam 参数
  48. // 返回: void
  49. //---------------------------------------------------------------------------
  50. #ifdef WIN32
  51. unsigned __stdcall MyThreadProc(LPVOID lpParam)
  52. #else
  53. void * MyThreadProc(LPVOID lpParam)
  54. #endif
  55. {
  56.  printf("start thread %dn", lpParam);
  57. KThread* pThread = (KThread*)lpParam;
  58. #ifdef WIN32
  59. return pThread->ThreadFunction();
  60. #else
  61. return (void *)pThread->ThreadFunction();
  62. #endif
  63. // return 0;
  64. }
  65. //---------------------------------------------------------------------------
  66. // 函数: ThreadFunction
  67. // 功能: 析购函数
  68. // 参数: void
  69. // 返回: void
  70. //---------------------------------------------------------------------------
  71. DWORD KThread::ThreadFunction()
  72. {
  73. m_ThreadFunc(m_ThreadParam);
  74. return 0;
  75. }
  76. //---------------------------------------------------------------------------
  77. // 函数: Create
  78. // 功能: 创建线程
  79. // 参数: func 线程函数
  80. // arg  线程参数
  81. // 返回: BOOL
  82. //---------------------------------------------------------------------------
  83. BOOL KThread::Create(TThreadFunc lpFunc, void* lpParam)
  84. {
  85. #ifdef WIN32
  86. m_ThreadFunc   = lpFunc;
  87. m_ThreadParam  = lpParam;
  88. m_ThreadHandle = (HANDLE)_beginthreadex(
  89. NULL, // SD
  90. 0, // initial stack size
  91. MyThreadProc, // thread function
  92. this, // thread argument
  93. 0, // creation option
  94. (unsigned*)&m_ThreadId); // thread identifier
  95. return (m_ThreadHandle != NULL);
  96. #else
  97.      m_ThreadFunc   = lpFunc;
  98.      int ret = pthread_create(&p_thread, NULL, MyThreadProc, this);
  99.      printf("create thread %d return %dn", (int)p_thread, ret);
  100. #endif
  101. // return FALSE;
  102. }
  103. //---------------------------------------------------------------------------
  104. // 函数: Destroy
  105. // 功能: 销毁线程
  106. // 参数: void
  107. // 返回: void
  108. //---------------------------------------------------------------------------
  109. void KThread::Destroy()
  110. {
  111. #ifdef WIN32
  112. TerminateThread(m_ThreadHandle, 0);
  113. #endif
  114. }
  115. //---------------------------------------------------------------------------
  116. // 函数: Suspend
  117. // 功能: 挂起线程
  118. // 参数: void
  119. // 返回: void
  120. //---------------------------------------------------------------------------
  121. void KThread::Suspend()
  122. {
  123. #ifdef WIN32
  124.  SuspendThread(m_ThreadHandle);
  125. #endif
  126. }
  127. //---------------------------------------------------------------------------
  128. // 函数: Resume
  129. // 功能: 唤醒线程
  130. // 参数: void
  131. // 返回: void
  132. //---------------------------------------------------------------------------
  133. void KThread::Resume()
  134. {
  135. #ifdef WIN32
  136. ResumeThread(m_ThreadHandle);
  137. #endif
  138. }
  139. //---------------------------------------------------------------------------
  140. // 函数: IsRunning
  141. // 功能: 判断线程是否在运行
  142. // 参数: void
  143. // 返回: BOOL
  144. //---------------------------------------------------------------------------
  145. BOOL KThread::IsRunning()
  146. {
  147. #ifdef WIN32
  148. DWORD dwResult = WaitForSingleObject(m_ThreadHandle, 0);
  149. return (dwResult == WAIT_OBJECT_0);
  150. #endif
  151. // return FALSE;
  152. }
  153. //---------------------------------------------------------------------------
  154. // 函数: WaitForExit
  155. // 功能: 等待线程结束
  156. // 参数: void
  157. // 返回: void
  158. //---------------------------------------------------------------------------
  159. void KThread::WaitForExit()
  160. {
  161. #ifdef WIN32
  162. WaitForSingleObject(m_ThreadHandle, INFINITE);
  163. #endif
  164. }
  165. //---------------------------------------------------------------------------
  166. // 函数: GetPriority
  167. // 功能: 取得线程优先级
  168. // 参数: void
  169. // 返回: int
  170. //---------------------------------------------------------------------------
  171. int KThread::GetPriority()
  172. {
  173. #ifdef WIN32
  174. return GetThreadPriority(m_ThreadHandle);
  175. #endif
  176. // return 0;
  177. }
  178. //---------------------------------------------------------------------------
  179. // 函数: SetPriority
  180. // 功能: 设置线程优先级
  181. // 参数: void
  182. // 返回: BOOL
  183. //---------------------------------------------------------------------------
  184. BOOL KThread::SetPriority(int priority)
  185. {
  186. #ifdef WIN32
  187. return SetThreadPriority(m_ThreadHandle, priority);
  188. #endif
  189. // return FALSE;
  190. }