ChangeLogTag:Thu Jan 1 15:20:30 2004 Steve Huston <shuston@riverace.com>

1 files changed, 61 insertions, 0 deletions

diff --git a/examples/APG/ThreadSafety/TSS.cpp b/examples/APG/ThreadSafety/TSS.cpp
new file mode 100644
index 00000000000..62fea96afb5
--- /dev/null
+++ b/examples/APG/ThreadSafety/TSS.cpp
@@ -0,0 +1,61 @@
+// $Id$
+
+#include "ace/Synch.h"
+#include "ace/Task.h"
+#include "ClientContext.h"
+
+
+void*
+ClientContext::get_attribute (const char *name)
+{
+  void * value;
+  attributeMap_.find (name, value);
+  return value;
+}
+
+void
+ClientContext::set_attribute (const char *name, void *value)
+{
+  attributeMap_.bind (name, value);
+}
+
+// Listing 2 code/ch14
+class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
+{
+public:
+  virtual int svc (void)
+  {
+    ACE_thread_t tid = this->thr_mgr ()->thr_self ();
+    // Set our identifier in TSS.
+    this->tss_ctx_->set_attribute ("thread_id", &tid);
+
+    while (handle_requests () > 0)
+      ;
+
+    return 0;
+  }
+
+  int handle_requests (void)
+  {
+    ACE_thread_t *tid =
+      (ACE_thread_t*)this->tss_ctx_->get_attribute ("thread_id");
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) TSS TID: %d \n"),
+                *tid));
+
+    // do work.
+    return -1;
+  }
+
+private:
+  ACE_TSS<ClientContext> tss_ctx_;
+};
+// Listing 2
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  HA_CommandHandler handler;
+  handler.activate (THR_NEW_LWP | THR_JOINABLE, 5);
+  handler.wait ();
+  return 0;
+}
+