ACE/examples/APG/ThreadManagement/Pool.cpp

   1 #include "ace/config-lite.h"
   2 #if defined (ACE_HAS_THREADS)
   3
   4 #include "ace/Task.h"
   5 #include "ace/Log_Msg.h"
   6
   7 // Listing 1 code/ch13
   8 class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
   9 {
  10 public:
  11   virtual int svc ()
  12   {
  13     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) starting up\n")));
  14     ACE_Message_Block *mb = 0;
  15     if (this->getq (mb) == -1)
  16       return -1;
  17     // ... do something with the message.
  18     return 0;
  19   }
  20 };
  21 // Listing 1
  22 // Listing 2 code/ch13
  23 int ACE_TMAIN (int, ACE_TCHAR *[])
  24 {
  25   HA_CommandHandler handler;
  26
  27   // Create 4 threads.
  28   handler.activate (THR_NEW_LWP | THR_JOINABLE, 4);
  29   handler.wait ();
  30   return 0;
  31 }
  32 // Listing 2
  33
  34 #else
  35 #include "ace/OS_main.h"
  36 #include "ace/OS_NS_stdio.h"
  37
  38 int ACE_TMAIN (int, ACE_TCHAR *[])
  39 {
  40   ACE_OS::puts (ACE_TEXT ("This example requires threads."));
  41   return 0;
  42 }
  43
  44 #endif /* ACE_HAS_THREADS */