Changeset 3327 for Core/branches/0075_TR_SCRIPTING/Threading/I_Thread.hpp

Timestamp:

01/29/10 13:00:29 (6 months ago)

Author:

mgray

Message:

Added getCurrentThreadId() and getThreadId() method implementations to Zen::Threading::I_Thread and associated concrete implementations.

Files:

• Core/branches/0075_TR_SCRIPTING/Threading/I_Thread.hpp (modified) (4 diffs)

Core/branches/0075_TR_SCRIPTING/Threading/I_Thread.hpp

@@ -31 +31 @@
 #include <boost/noncopyable.hpp>
 
+#include <string>
+
 //-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~
 namespace Zen {
@@ -42 +44 @@
     /// @{
 public:
+    struct ThreadId;
     /// @}
 
@@ -56 +59 @@
         /// Block until this I_Thread has terminated.
         virtual void join() = 0;
+
+    /// Returns a copy of running (kernel-)thread's id, rendered in this 
+    /// object's id format (so that you can safely compare it to 
+    /// getThreadId()).  Always valid.
+    virtual ThreadId getCurrentThreadId() const = 0;
+
+    /// Returns a copy of this object's id. Not valid until after start().
+    virtual const ThreadId& getThreadId() const = 0; 
     /// @}
 
@@ -62 +73 @@
 public:
     static void sleepForMilliseconds(unsigned const _milliseconds); // current thread will sleep
+    /// @}
+
+    /// @name Inner Classes
+    /// @{
+public:
+    struct ThreadId
+    {
+        /// @name Inner Interfaces
+        /// @{
+    public:
+        class I_NativeThreadId
+        {
+            /// @name Types
+            /// @{
+        public:
+            /// @}
+
+            /// @name I_NativeThreadId interface
+            /// @{
+        public:
+            virtual bool operator==(const I_NativeThreadId& _otherId) const = 0;
+            virtual bool operator!=(const I_NativeThreadId& _otherId) const = 0;
+            virtual I_NativeThreadId* clone() const = 0;
+            virtual std::string toString() const = 0;
+            /// @}
+
+            /// @name 'Structors
+            /// @{
+        public:
+                     I_NativeThreadId() {}
+            virtual ~I_NativeThreadId() {}
+            /// @}
+
+        };  // class I_NativeThreadId
+        /// @}
+
+        /// @name ThreadId implementation
+        /// @{
+    public:
+        ThreadId& operator=  (const ThreadId& _otherId)       {delete m_pNativeThreadId; m_pNativeThreadId = _otherId.m_pNativeThreadId->clone(); return *this;}
+        bool      operator== (const ThreadId& _otherId) const {return (m_pNativeThreadId == _otherId.m_pNativeThreadId) || ( m_pNativeThreadId &&  _otherId.m_pNativeThreadId && (*m_pNativeThreadId == *_otherId.m_pNativeThreadId));}
+        bool      operator!= (const ThreadId& _otherId) const {return (m_pNativeThreadId != _otherId.m_pNativeThreadId) && (!m_pNativeThreadId || !_otherId.m_pNativeThreadId || (*m_pNativeThreadId != *_otherId.m_pNativeThreadId));}
+                  operator std::string ()               const {return m_pNativeThreadId ? m_pNativeThreadId->toString() : "";}
+        std::string toString()                          const {return m_pNativeThreadId ? m_pNativeThreadId->toString() : "";}
+        /// @}
+
+        /// @name 'Structors
+        /// @{
+    public:
+         ThreadId(I_NativeThreadId* const _pId = NULL) : m_pNativeThreadId(_pId)                                {}
+         ThreadId(const ThreadId& _otherId)            : m_pNativeThreadId(_otherId.m_pNativeThreadId->clone()) {}
+        ~ThreadId()                                                                                             {delete m_pNativeThreadId;}
+        /// @}
+
+        /// @name Member variables
+        /// @{
+    public:
+        I_NativeThreadId* m_pNativeThreadId;
+        /// @}
+
+    };  // struct ThreadId
     /// @}