ACE/examples/APG/ThreadManagement/Signals.cpp

   1 #include "ace/config-lite.h"
   2 #if defined (ACE_HAS_THREADS)
   3
   4 #include "ace/OS_NS_time.h"
   5 #include "ace/OS_NS_unistd.h"
   6 #include "ace/Task.h"
   7 #include "ace/Log_Msg.h"
   8 #include "ace/Signal.h"
   9 #include "ace/Sig_Handler.h"
  10
  11 // Listing 1 code/ch13
  12 class SignalableTask : public ACE_Task<ACE_MT_SYNCH>
  13 {
  14 public:
  15   virtual int handle_signal (int signum, siginfo_t *  = 0, ucontext_t * = 0)
  16   {
  17     if (signum == SIGUSR1)
  18       {
  19         ACE_DEBUG ((LM_DEBUG,
  20                     ACE_TEXT ("(%t) received a %S signal\n"),
  21                     signum));
  22         handle_alert ();
  23       }
  24     return 0;
  25   }
  26
  27   virtual int svc ()
  28   {
  29     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) Starting thread\n")));
  30
  31     while (1)
  32       {
  33         ACE_Message_Block* mb = 0;
  34         ACE_Time_Value tv (0, 1000);
  35         tv += ACE_OS::time (0);
  36         int result = this->getq (mb, &tv);
  37         if (result == -1 && errno == EWOULDBLOCK)
  38           continue;
  39         else
  40           process_message (mb);
  41       }
  42
  43       ACE_NOTREACHED (return 0);
  44     }
  45
  46   void handle_alert ();
  47   void process_message (ACE_Message_Block *mb);
  48 };
  49 // Listing 1
  50
  51 void
  52 SignalableTask::process_message (ACE_Message_Block *)
  53 {
  54 }
  55
  56 void
  57 SignalableTask::handle_alert ()
  58 {
  59 }
  60
  61 // Listing 2 code/ch13
  62 int ACE_TMAIN (int, ACE_TCHAR *[])
  63 {
  64   SignalableTask handler;
  65   handler.activate (THR_NEW_LWP | THR_JOINABLE , 5);
  66
  67   ACE_Sig_Handler sh;
  68   sh.register_handler (SIGUSR1, &handler);
  69
  70   ACE_OS::sleep (1);
  71
  72   ACE_Thread_Manager::instance () ->
  73     kill_grp (handler.grp_id (), SIGUSR1);
  74   handler.wait ();
  75   return 0;
  76 }
  77 // Listing 2
  78
  79 #else
  80 #include "ace/OS_main.h"
  81 #include "ace/OS_NS_stdio.h"
  82
  83 int ACE_TMAIN (int, ACE_TCHAR *[])
  84 {
  85   ACE_OS::puts (ACE_TEXT ("This example requires threads."));
  86   return 0;
  87 }
  88
  89 #endif /* ACE_HAS_THREADS */