ACE/examples/APG/Timers/Alarm.cpp

   1 #include "ace/OS_NS_unistd.h"
   2 #include "ace/OS_NS_sys_time.h"
   3
   4 // Listing 1 code/ch20
   5 #include "ace/Timer_Queue_Adapters.h"
   6 #include "ace/Timer_Heap.h"
   7
   8 typedef ACE_Async_Timer_Queue_Adapter<ACE_Timer_Heap> Timer;
   9 // Listing 1
  10
  11 class CB : public ACE_Event_Handler
  12 {
  13 public:
  14   CB (int id) : id_(id) { }
  15
  16   virtual int handle_timeout (const ACE_Time_Value &,
  17                               const void *arg)
  18   {
  19     ACE_TRACE ("CB::handle_timeout");
  20
  21     const int *val = static_cast<const int*> (arg);
  22     ACE_ASSERT ((*val) == id_);
  23
  24     ACE_UNUSED_ARG (val);
  25
  26     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Timer expired\n")));
  27     return 0;
  28   }
  29
  30 private:
  31   int id_;
  32 };
  33
  34 // Listing 2 code/ch20
  35 int ACE_TMAIN (int, ACE_TCHAR *[])
  36 {
  37   // Create the timer such that it blocks all signals
  38   // when it goes off.
  39   Timer timer;
  40
  41   // Schedule a timer to go off 2 seconds later and then
  42   // after every 4 seconds.
  43   CB cb (1);
  44   int arg = 1;
  45   ACE_Time_Value initial (2);
  46   ACE_Time_Value repeat (4);
  47   initial += ACE_OS::gettimeofday ();
  48   timer.schedule (&cb, &arg, initial, repeat);
  49
  50   while (1)      // Don't let the main thread exit.
  51     ACE_OS::sleep (2);
  52   ACE_NOTREACHED (return 0);     // Not reached.
  53 }
  54 // Listing 2
  55