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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 并行计算 > 查看源码
Win32Condition.cpp
资源名称：fastgrid-4.2.1-141-src.tar.gz　[点击查看]
上传用户：chinafayin
上传日期：2022-04-05
资源大小：153k
文件大小：3k
源码类别：

并行计算

开发平台：

Visual C++

Win32Condition.cpp：源码内容
  1. //
  2. // OpenThread library, Copyright (C) 2002 - 2003  The Open Thread Group
  3. //
  4. // This library is free software; you can redistribute it and/or
  5. // modify it under the terms of the GNU Lesser General Public
  6. // License as published by the Free Software Foundation; either
  7. // version 2.1 of the License, or (at your option) any later version.
  8. //
  9. // This library is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12. // Lesser General Public License for more details.
  13. // 
  14. // You should have received a copy of the GNU Lesser General Public
  15. // License along with this library; if not, write to the Free Software
  16. // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17. //
  18. //
  19. // Win32Condition.c++ - C++ Condition class built on top of posix threads.
  20. // ~~~~~~~~~~~~~~~~~~~~
  21. //
  22. #include "../Condition"
  23. #include "Win32ConditionPrivateData.h"
  25. using namespace OpenThreads;
  26. Win32ConditionPrivateData::~Win32ConditionPrivateData()
  27. {
  28. }
  30. //----------------------------------------------------------------------------
  31. //
  32. // Decription: Constructor
  33. //
  34. // Use: public.
  35. //
  36. Condition::Condition() {
  37.     Win32ConditionPrivateData *pd =
  38.         new Win32ConditionPrivateData();
  39.     _prvData = static_cast<void *>(pd);
  40. }
  41. //----------------------------------------------------------------------------
  42. //
  43. // Decription: Destructor
  44. //
  45. // Use: public.
  46. //
  47. Condition::~Condition() {
  48.     Win32ConditionPrivateData *pd =
  49.        static_cast<Win32ConditionPrivateData *>(_prvData);
  51.     delete pd;
  52. }
  54. //----------------------------------------------------------------------------
  55. //
  56. // Decription: wait on a condition
  57. //
  58. // Use: public.
  59. //
  60. int Condition::wait(Mutex *mutex) {
  62.     Win32ConditionPrivateData *pd =
  63.         static_cast<Win32ConditionPrivateData *>(_prvData);
  65.     return pd->wait(*mutex, INFINITE);
  66. }
  67. //----------------------------------------------------------------------------
  68. //
  69. // Decription: wait on a condition, for a specified period of time
  70. //
  71. // Use: public.
  72. //
  73. int Condition::wait(Mutex *mutex, unsigned long ms) {
  74.     Win32ConditionPrivateData *pd =
  75.         static_cast<Win32ConditionPrivateData *>(_prvData);
  77.     return pd->wait(*mutex, ms);
  78. }
  79. //----------------------------------------------------------------------------
  80. //
  81. // Decription: signal a thread to wake up.
  82. //
  83. // Use: public.
  84. //
  85. int Condition::signal() {
  86.     Win32ConditionPrivateData *pd =
  87.         static_cast<Win32ConditionPrivateData *>(_prvData);
  88.     return pd->signal();
  89. }
  90. //----------------------------------------------------------------------------
  91. //
  92. // Decription: signal many threads to wake up.
  93. //
  94. // Use: public.
  95. //
  96. int Condition::broadcast() {
  97.     Win32ConditionPrivateData *pd =
  98.         static_cast<Win32ConditionPrivateData *>(_prvData);
  99.     return pd->broadcast();
  100. }