ACE/apps/JAWS3/jaws3/Concurrency.h

   1 // -*- C++ -*-
   2 #ifndef JAWS_CONCURRENCY_H
   3 #define JAWS_CONCURRENCY_H
   4
   5 #include "ace/Task.h"
   6 #include "ace/Singleton.h"
   7 #include "ace/Synch_Traits.h"
   8
   9 #include "jaws3/Export.h"
  10 #include "jaws3/Protocol_Handler.h"
  11
  12
  13 typedef ACE_Task<ACE_SYNCH> JAWS_CONCURRENCY_TASK;
  14
  15 class JAWS_Export JAWS_Concurrency_Impl : public JAWS_CONCURRENCY_TASK
  16 {
  17 public:
  18   virtual ~JAWS_Concurrency_Impl () {};
  19
  20   virtual int putq (JAWS_Protocol_Handler *ph) = 0;
  21
  22   virtual int getq (JAWS_Protocol_Handler *&ph) = 0;
  23
  24   int svc ();
  25 };
  26
  27
  28 // Include the templates here.
  29 #include "jaws3/Concurrency_T.h"
  30
  31
  32 template<>
  33 class JAWS_Export JAWS_Concurrency_Bridge<JAWS_Concurrency_Impl>
  34 {
  35 public:
  36   JAWS_Concurrency_Bridge (JAWS_Concurrency_Impl *impl = 0);
  37
  38   int putq (JAWS_Protocol_Handler *ph);
  39   int getq (JAWS_Protocol_Handler *&ph);
  40
  41   void shutdown ();
  42
  43 protected:
  44   JAWS_Concurrency_Impl *impl_;
  45 };
  46
  47
  48 #ifndef JAWS_CONCURRENCY_CONCRETE_IMPL
  49 #define JAWS_CONCURRENCY_CONCRETE_IMPL JAWS_Concurrency_Impl
  50 #endif /* JAWS_CONCURRENCY_CONCRETE_IMPL */
  51
  52
  53 class JAWS_Export JAWS_Concurrency
  54   : public JAWS_Concurrency_Bridge<JAWS_CONCURRENCY_CONCRETE_IMPL>
  55 {
  56 public:
  57   static JAWS_Concurrency * instance ()
  58   {
  59     return ACE_Singleton<JAWS_Concurrency, ACE_SYNCH_MUTEX>::instance ();
  60   }
  61 };
  62
  63
  64 #endif /* JAWS_CONCURRENCY_H */