我正在围绕Win32线程和pthreads做包装器类,其风格类似于c ++ 11线程api。
我的问题是关于在实际线程退出时更新线程对象实例。下面是我有一个解决方案,但是我不确定它是否安全。

/* Thread wrapper class */
    class Thread
    {
    public:
        enum ThreadState
        {
            DETACHED = 0,
            RUNNING
        };

        Thread();
        Thread(void* (*start) (void*), void* arg);
        ~Thread();

        Thread& operator=(Thread& other);
        void Join();
        int32_t SetPriority(int32_t priority);
        void Detach();
        ThreadHandle GetNativeHandle();
        ThreadState GetThreadState();

    private:
        ThreadHandle mHandle;
        ThreadState mState;
        void* (*mFunctionPointer) (void*);
        void* mArg;

        static void* Run(void* arg);
        ThreadHandle _CreateThread(void* (*start) (void*), void* arg);
        void _JoinThread(ThreadHandle& handle);

    };


第二个构造函数启动一个线程。这是实现:

    Thread::Thread(void* (*start) (void*), void* arg)
    {
        mFunctionPointer = start;
        mArg = arg;
        mState = Thread::RUNNING;

        mHandle = _CreateThread(&Run, (void*)this);
        if (!mHandle)
            mState = Thread::DETACHED;
    }


它创建一个线程,该线程运行Run方法并传递指向该对象实例的指针。原因是线程一旦执行了函数,便将状态设置为DETACHED以表示已完成。

这是运行方法

    void* Thread::Run(void* arg)
    {
        Thread* thread = static_cast<Thread*>(arg);

        if (thread && thread->mFunctionPointer && thread->mArg && thread->mState == Thread::RUNNING)
            thread->mFunctionPointer(thread->mArg);

        if (thread && thread->mFunctionPointer && thread->mArg && thread->mState == Thread::RUNNING)
            thread->Detach();

        return NULL;
    }


这也是Detach(),它也在线程析构函数上调用:

    void Thread::Detach()
    {
        mState = Thread::DETACHED;
        mHandle = NULL;
        mArg = NULL;
        mFunctionPointer = NULL;
    }


我觉得这根本不安全。例如,如果Thread对象构造在堆栈上,并且在其线程运行时超出范围。线程对象析构函数的状态和数据成员为NULL,但是内存位置可能会被覆盖否?

有什么好办法解决这个问题吗?

谢谢

最佳答案

如果Thread实例超出范围而没有加入线程,那您就注定了。使Run()成为自由或静态函数并复制所有数据,该函数需要运行到动态分配的内存中,并让Run()释放该内存。

Run()中不需要进行太多测试。由于您的c'tor参数已经与CreateThread()兼容,只需将函数和参数传递给CreateThread,就可以了。

亲切的问候

托斯滕

关于c++ - 线程包装器实现问题,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/11507787/

10-11 22:40
查看更多