ACE/examples/APG/ThreadSafety/TSS.cpp

   1 #include "ace/config-lite.h"
   2 #if defined (ACE_HAS_THREADS)
   3
   4 #include "ace/Synch.h"
   5 #include "ace/Task.h"
   6 #include "ClientContext.h"
   7
   8
   9 void*
  10 ClientContext::get_attribute (const char *name)
  11 {
  12   void * value = 0;
  13   attributeMap_.find (name, value);
  14   return value;
  15 }
  16
  17 void
  18 ClientContext::set_attribute (const char *name, void *value)
  19 {
  20   attributeMap_.bind (name, value);
  21 }
  22
  23 // Listing 2 code/ch14
  24 class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
  25 {
  26 public:
  27   virtual int svc ()
  28   {
  29     ACE_thread_t tid = this->thr_mgr ()->thr_self ();
  30     // Set our identifier in TSS.
  31     this->tss_ctx_->set_attribute ("thread_id", &tid);
  32
  33     while (handle_requests () > 0)
  34       ;
  35
  36     return 0;
  37   }
  38
  39   int handle_requests ()
  40   {
  41     ACE_thread_t *tid =
  42       (ACE_thread_t*)this->tss_ctx_->get_attribute ("thread_id");
  43     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) TSS TID: %d\n"),
  44                 *tid));
  45
  46     // do work.
  47     return -1;
  48   }
  49
  50 private:
  51   ACE_TSS<ClientContext> tss_ctx_;
  52 };
  53 // Listing 2
  54
  55 int ACE_TMAIN (int, ACE_TCHAR *[])
  56 {
  57   HA_CommandHandler handler;
  58   handler.activate (THR_NEW_LWP | THR_JOINABLE, 5);
  59   handler.wait ();
  60   return 0;
  61 }
  62
  63 #else
  64 #include "ace/OS_main.h"
  65 #include "ace/OS_NS_stdio.h"
  66
  67 int ACE_TMAIN (int, ACE_TCHAR *[])
  68 {
  69   ACE_OS::puts (ACE_TEXT ("This example requires threads."));
  70   return 0;
  71 }
  72
  73 #endif /* ACE_HAS_THREADS */