ACE/apps/JAWS3/jaws3/THYBRID_Concurrency.h

   1 /* -*- c++ -*- */
   2 #ifndef JAWS_THYBRID_CONCURRENCY_H
   3 #define JAWS_THYBRID_CONCURRENCY_H
   4
   5 #include "ace/Atomic_Op.h"
   6
   7 #include "jaws3/Concurrency.h"
   8
   9 class JAWS_Export JAWS_THYBRID_Concurrency : public JAWS_Concurrency_Impl
  10 {
  11 public:
  12   JAWS_THYBRID_Concurrency ();
  13
  14   int putq (JAWS_Protocol_Handler *ph);
  15
  16   int getq (JAWS_Protocol_Handler *&ph);
  17
  18   static JAWS_THYBRID_Concurrency * instance ()
  19   {
  20     return ACE_Singleton<JAWS_THYBRID_Concurrency, ACE_SYNCH_MUTEX>
  21            ::instance ();
  22   }
  23
  24 private:
  25   ACE_Atomic_Op<ACE_SYNCH_MUTEX, int> getting_;
  26   int min_number_of_threads_;
  27   int max_number_of_threads_;
  28   int shutdown_task_;
  29   int error_;
  30 };
  31
  32 #endif /* JAWS_THYBRID_CONCURRENCY_H */