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

外挂编程

开发平台:

Windows_Unix

  1. /*
  2.  *  OpenKore C++ Standard Library
  3.  *  Copyright (C) 2006,2007  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 PosixThread: public ThreadImplementation {
  23. private:
  24. pthread_t thread;
  25. Runnable *runnable;
  26. bool detached;
  27. bool runnableShouldBeFreed;
  28. static void *
  29. entry(void *arg) {
  30. PosixThread *self = (PosixThread *) arg;
  31. self->runnable->run();
  32. if (self->detached && self->runnableShouldBeFreed) {
  33. delete self->runnable;
  34. }
  35. self->unref();
  36. return NULL;
  37. }
  38. public:
  39. virtual void
  40. start(Runnable *runnable, bool detached, bool runnableShouldBeFreed) throw(ThreadException) {
  41. this->runnable = runnable;
  42. this->detached = detached;
  43. this->runnableShouldBeFreed = runnableShouldBeFreed;
  44. if (detached) {
  45. pthread_attr_t attr;
  46. if (pthread_attr_init(&attr) != 0) {
  47. throw ThreadException("Cannot initialize pthread attribute.");
  48. }
  49. if (pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED) != 0) {
  50. throw ThreadException("Cannot set pthread detach state.");
  51. }
  52. ref();
  53. if (pthread_create(&thread, &attr, entry, this) != 0) {
  54. unref();
  55. throw ThreadException("Cannot create a thread.");
  56. }
  57. pthread_attr_destroy(&attr);
  58. } else {
  59. ref();
  60. if (pthread_create(&thread, NULL, entry, this) != 0) {
  61. unref();
  62. throw ThreadException("Cannot create a thread.");
  63. }
  64. }
  65. }
  66. virtual void
  67. join() {
  68. pthread_join(thread, NULL);
  69. }
  70. };