线程包装器实现问题

Thread wrapper implementation issue

本文关键字:问题 实现 包装 线程      更新时间:2023-10-16

我正在做一个围绕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,就可以了。

问候

Torsten