ACE/apps/JAWS3/jaws3/TPOOL_Concurrency.h

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