1 files changed, 122 insertions, 0 deletions
diff --git a/cpp/include/IceUtil/Thread.h b/cpp/include/IceUtil/Thread.h
new file mode 100644
index 00000000000..4d1a9551cc5
--- /dev/null
+++ b/cpp/include/IceUtil/Thread.h
@@ -0,0 +1,122 @@
+// **********************************************************************
+//
+// Copyright (c) 2001
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+#ifndef ICE_UTIL_THREAD_H
+#define ICE_UTIL_THREAD_H
+
+#include <IceUtil/Shared.h>
+#include <IceUtil/Handle.h>
+
+namespace IceUtil
+{
+
+#ifdef WIN32
+struct HandleWrapper : public Shared
+{
+    HandleWrapper(HANDLE h) :
+	handle(h)
+    {
+    }
+    ~HandleWrapper()
+    {
+	if (handle != 0)
+	{
+	    CloseHandle(handle);
+	}
+    }
+
+    HANDLE handle;
+};
+
+typedef Handle<HandleWrapper> HandleWrapperPtr;
+#endif
+
+//
+//
+//
+class ICE_UTIL_API ThreadControl
+{
+public:
+
+    ThreadControl();
+
+#ifdef WIN32
+    ThreadControl(const HandleWrapperPtr&, unsigned);
+#else
+    ThreadControl(pthread_t);
+#endif
+
+    bool operator==(const ThreadControl&) const;
+    bool operator!=(const ThreadControl&) const;
+    bool operator<(const ThreadControl&) const;
+
+    //
+    // Wait until the controlled thread terminates. The call has POSIX
+    // semantics.
+    //
+    // At most one thread can wait for the termination of a given
+    // thread.C alling join on a thread on which another thread is
+    // already waiting for termination results in undefined behaviour.
+    //
+    void join();
+
+    //
+    // Sleep for msec milliseconds.
+    //
+    static void sleep(long);
+
+    //
+    // Yield the CPU.
+    //
+    static void yield();
+
+private:
+
+#ifdef WIN32
+    HandleWrapperPtr _handle;
+    unsigned _id;
+#else
+    pthread_t _id;
+#endif
+};
+
+class ICE_UTIL_API Thread : public IceUtil::Shared
+{
+public:
+
+    Thread();
+    virtual ~Thread();
+
+    virtual void run() = 0;
+
+    ThreadControl start();
+
+    ThreadControl getThreadControl();
+
+    bool operator==(const Thread&) const;
+    bool operator!=(const Thread&) const;
+    bool operator<(const Thread&) const;
+
+private:
+
+#ifdef WIN32
+    unsigned _id;
+    HandleWrapperPtr _handle;
+#else
+    pthread_t _id;
+#endif
+};
+
+typedef Handle<Thread> ThreadPtr;
+    
+} // End namespace IceUtil
+
+#endif
+