ACE/apps/JAWS3/jaws3/TPR_Concurrency.h

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