TAO/tao/CSD_ThreadPool/CSD_TP_Synch_Helper.inl

   1 // -*- C++ -*-
   2 #include "ace/Guard_T.h"
   3
   4 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 ACE_INLINE
   7 TAO::CSD::TP_Synch_Helper::TP_Synch_Helper()
   8   : state_(PENDING),
   9     condition_(this->lock_)
  10 {
  11 }
  12
  13 ACE_INLINE
  14 TAO::CSD::TP_Synch_Helper::~TP_Synch_Helper()
  15 {
  16 }
  17
  18 ACE_INLINE
  19 bool
  20 TAO::CSD::TP_Synch_Helper::wait_while_pending()
  21 {
  22   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, guard, this->lock_, false);
  23
  24   while (this->state_ == PENDING)
  25     {
  26       this->condition_.wait();
  27     }
  28
  29   return (this->state_ == DISPATCHED);
  30 }
  31
  32 ACE_INLINE
  33 void
  34 TAO::CSD::TP_Synch_Helper::dispatched()
  35 {
  36   ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->lock_);
  37   this->state_ = DISPATCHED;
  38   this->condition_.signal();
  39 }
  40
  41 ACE_INLINE
  42 void
  43 TAO::CSD::TP_Synch_Helper::cancelled()
  44 {
  45   ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->lock_);
  46   this->state_ = CANCELLED;
  47   this->condition_.signal();
  48 }
  49
  50 TAO_END_VERSIONED_NAMESPACE_DECL