Thread.cpp.svn-base
上传用户:market2
上传日期:2018-11-18
资源大小:18786k
文件大小:2k
源码类别:

外挂编程

开发平台:

Windows_Unix

  1. /*
  2.  *  OpenKore C++ Standard Library
  3.  *  Copyright (C) 2006  VCL
  4.  *
  5.  *  This library is free software; you can redistribute it and/or
  6.  *  modify it under the terms of the GNU Lesser General Public
  7.  *  License as published by the Free Software Foundation; either
  8.  *  version 2.1 of the License, or (at your option) any later version.
  9.  *
  10.  *  This library is distributed in the hope that it will be useful,
  11.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13.  *  Lesser General Public License for more details.
  14.  *
  15.  *  You should have received a copy of the GNU Lesser General Public
  16.  *  License along with this library; if not, write to the Free Software
  17.  *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  18.  *  MA  02110-1301  USA
  19.  */
  20. // Do not compile this file independently, it's supposed to be automatically
  21. // included by another source file.
  22. class Win32Thread: public ThreadImplementation {
  23. private:
  24. HANDLE thread;
  25. Runnable *runnable;
  26. bool detached;
  27. bool runnableShouldBeFreed;
  28. static DWORD WINAPI
  29. entry(LPVOID arg) {
  30. Win32Thread *self = (Win32Thread *) arg;
  31. self->runnable->run();
  32. if (self->detached) {
  33. CloseHandle(self->thread);
  34. if (self->runnableShouldBeFreed) {
  35. delete self->runnable;
  36. }
  37. }
  38. self->unref();
  39. return 0;
  40. }
  41. public:
  42. virtual void
  43. start(Runnable *runnable, bool detached, bool runnableShouldBeFreed) throw(ThreadException) {
  44. DWORD threadID;
  45. this->runnable = runnable;
  46. this->detached = detached;
  47. this->runnableShouldBeFreed = runnableShouldBeFreed;
  48. thread = CreateThread(NULL, 0, entry, this, CREATE_SUSPENDED, &threadID);
  49. if (thread == NULL) {
  50. throw ThreadException("Cannot create a thread.");
  51. } else {
  52. ref();
  53. if (ResumeThread(thread) == (DWORD) -1) {
  54. unref();
  55. CloseHandle(thread);
  56. throw ThreadException("Cannot resume thread.");
  57. }
  58. }
  59. }
  60. virtual void
  61. join() {
  62. WaitForSingleObject(thread, INFINITE);
  63. CloseHandle(thread);
  64. }
  65. };