ACE/examples/APG/ThreadSafety/Tokens.cpp

   1 #include "ace/Local_Tokens.h"
   2 #include "ace/Token_Manager.h"
   3 #include "ace/Task.h"
   4 #include "ace/OS_NS_time.h"
   5
   6 #if defined (ACE_HAS_TOKENS_LIBRARY)
   7
   8 class Device;
   9
  10 // Listing 1 code/ch14
  11 class HA_Device_Repository
  12 {
  13 public:
  14   enum { N_DEVICES = 100 };
  15
  16   HA_Device_Repository ()
  17   {
  18     for (int i = 0; i < N_DEVICES; i++)
  19       tokens_[i] = new ACE_Local_Mutex (0, 0, 1);
  20   }
  21
  22   ~HA_Device_Repository ()
  23   {
  24     for (int i = 0; i < N_DEVICES; i++)
  25       delete tokens_[i];
  26   }
  27
  28   int update_device (int device_id, char *commands)
  29   {
  30     this->tokens_[device_id]->acquire ();
  31
  32     Device *curr_device = this->devices_[device_id];
  33     internal_do (curr_device);
  34
  35     this->tokens_[device_id]->release ();
  36
  37     return 0;
  38   }
  39
  40   void internal_do (Device *device);
  41
  42 private:
  43   Device *devices_[N_DEVICES];
  44   ACE_Local_Mutex *tokens_[N_DEVICES];
  45   unsigned int seed_;
  46 };
  47 // Listing 1
  48
  49 void
  50 HA_Device_Repository::internal_do (Device *device)
  51 {
  52   ACE_UNUSED_ARG (device);    // Real code would use this.
  53   ACE_Time_Value tv (0, ACE_OS::rand_r (&this->seed_) % 10000);
  54   timespec_t t  = (timespec_t)tv;
  55   ACE_OS::nanosleep (&t);
  56 }
  57
  58 // Listing 2 code/ch14
  59 class HA_CommandHandler : public ACE_Task_Base
  60 {
  61 public:
  62   enum { N_THREADS = 5 };
  63
  64   HA_CommandHandler (HA_Device_Repository &rep) : rep_(rep)
  65   { }
  66
  67   int svc ()
  68   {
  69     for (int i = 0; i < HA_Device_Repository::N_DEVICES; i++)
  70       rep_.update_device (i, "");
  71     return 0;
  72   }
  73
  74 private:
  75   HA_Device_Repository &rep_;
  76 };
  77
  78 int ACE_TMAIN (int, ACE_TCHAR *[])
  79 {
  80   HA_Device_Repository rep;
  81   HA_CommandHandler handler (rep);
  82   handler.activate (THR_NEW_LWP | THR_JOINABLE,
  83                     HA_CommandHandler::N_THREADS);
  84   handler.wait ();
  85   return 0;
  86 }
  87 // Listing 2
  88
  89 #else /* defined (ACE_HAS_TOKENS_LIBRARY) */
  90
  91 int ACE_TMAIN (int, ACE_TCHAR *[])
  92 {
  93   ACE_ERROR ((LM_ERROR,
  94               ACE_TEXT ("local tokens not supported ")
  95               ACE_TEXT ("on this platform\n")));
  96   return 0;
  97 }
  98
  99 #endif /* defined (ACE_HAS_TOKENS_LIBRARY) */