Thread.h

Go to the documentation of this file.

/*  Thread.h - Thread wrapper
    Copyright (C) 2001-2004 Mark Weaver
    Written by Mark Weaver <mark@npsl.co.uk>

    Part of the Open-Win32 library.
    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Library General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.

    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Library General Public License for more details.

    You should have received a copy of the GNU Library General Public
    License along with this library; if not, write to the
    Free Software Foundation, Inc., 59 Temple Place - Suite 330,
    Boston, MA  02111-1307, USA.
*/

#ifndef OW32_Thread_h
#define OW32_Thread_h

#include <OW32/OW32Libs.h>
#include <OW32/XHANDLE.h>
#include <cassert>
#include <process.h>

// Open Win32 namespace
namespace OW32
{

class OW32_LIB_EXPORT CThread
{
private:
    XHANDLE m_hThread;
    DWORD m_dwThreadId;
    bool m_bAutoDelete;

    static unsigned int __stdcall RedirectThreadFunc(LPVOID arg)
    {
        return arg ? ((CThread *)arg)->RunHelper() : -1;
    }

    unsigned int RunHelper()
    {
        unsigned int ret = (unsigned int)-1;
        if (InitInstance()) {
            ret = Run(); // run thread fn in derived class
            ExitInstance();
        }
        if (m_bAutoDelete) // auto cleanup if required
            delete this;
        return ret;
    }

    CThread(const CThread& );
    CThread& operator=(const CThread& );

public:
    CThread(bool bAutoDelete=false) :
        m_bAutoDelete(bAutoDelete),
        m_dwThreadId((DWORD)-1)
    {
    }

    virtual ~CThread() {}

    virtual unsigned int Run()=0;

    virtual BOOL InitInstance() { return TRUE; }

    virtual void ExitInstance() {}

    bool GetAutoDelete() { return m_bAutoDelete; }

    void SetAutoDelete(bool bAutoDelete) { m_bAutoDelete = bAutoDelete; }

    BOOL Create()
    {
        unsigned thrdid;
        m_hThread = (HANDLE)_beginthreadex(NULL, 0, RedirectThreadFunc, this, 0, &thrdid);
        m_dwThreadId = thrdid;
        return TRUE;
    }

    void Close()
    {
        m_hThread.Close();
    }

    DWORD Suspend() { return SuspendThread(m_hThread); }

    DWORD Resume() { return ResumeThread(m_hThread); }

    int GetPriority() { return GetThreadPriority(m_hThread); }

    int SetPriority(int nPriority) { return SetThreadPriority(m_hThread, nPriority); }

    BOOL PostMessage(UINT Msg, WPARAM wParam, LPARAM lParam)
        { return PostThreadMessage(m_dwThreadId, Msg, wParam, lParam); }

    HANDLE GetHandle() { return m_hThread; }

    DWORD GetId() { return m_dwThreadId; }

    BOOL GetExitCode(LPDWORD lpExitCode) {
        assert(!m_bAutoDelete);
        return ::GetExitCodeThread(m_hThread, lpExitCode);
    }

    operator HANDLE() { return m_hThread; }

    operator DWORD() { return m_dwThreadId; }
};

} // namespace OW32

#endif // OW32_Thread_h

---