ACE/apps/JAWS/server/JAWS_Concurrency.cpp

   1 #include "JAWS_Concurrency.h"
   2
   3 JAWS_Concurrency_Base::JAWS_Concurrency_Base ()
   4 {
   5 }
   6
   7 int
   8 JAWS_Concurrency_Base::put (ACE_Message_Block *mb, ACE_Time_Value *tv)
   9 {
  10   return this->putq (mb, tv);
  11 }
  12
  13 int
  14 JAWS_Concurrency_Base::svc ()
  15 {
  16   int result = 0;
  17
  18   for (;;)
  19     {
  20       ACE_Message_Block *mb = 0;
  21
  22       // At this point we could set a timeout value so that the
  23       // threading strategy can delete a thread if there is nothing to
  24       // do.  Carefully think how to implement it so you don't leave
  25       // yourself with 0 threads.
  26
  27       result = this->getq (mb);
  28       if (result == -1 || mb == 0)
  29         break;
  30
  31       this->put_next (mb);
  32     }
  33   return 0;
  34 }
  35
  36 JAWS_Dispatch_Policy::JAWS_Dispatch_Policy ()
  37 {
  38 }
  39
  40 JAWS_Dispatch_Policy::~JAWS_Dispatch_Policy ()
  41 {
  42 }
  43
  44 JAWS_Dispatcher::JAWS_Dispatcher (JAWS_Dispatch_Policy *policy)
  45   : policy_(policy)
  46 {
  47 }
  48
  49 JAWS_Thread_Pool_Task::JAWS_Thread_Pool_Task (long flags,
  50                                               int nthreads,
  51                                               int maxthreads)
  52   : nthreads_ (nthreads),
  53     maxthreads_ (maxthreads)
  54 {
  55   if (this->activate (flags, nthreads) == -1)
  56     ACE_ERROR ((LM_ERROR, "%p\n", "JAWS_Thread_Pool_Task::activate"));
  57 }
  58
  59 JAWS_Thread_Per_Task::JAWS_Thread_Per_Task (long flags, int maxthreads)
  60   : flags_ (flags),
  61     maxthreads_ (maxthreads)
  62 {
  63 }
  64
  65 int
  66 JAWS_Thread_Per_Task::put (ACE_Message_Block *mb, ACE_Time_Value *tv)
  67 {
  68   const int force_active = 1;
  69   const int nthreads = 1;
  70
  71   if (this->activate (this->flags_, nthreads, force_active) == -1)
  72     ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "JAWS_Thread_Pool_Task::activate"),
  73                       -1);
  74
  75   this->putq (mb, tv);
  76
  77   return 0;
  78 }