Bugfix for double free of RefBase objects in multi-threads environment. · Pull Request !55 · OpenHarmony/commonlibrary_c_utils

在多线程环境下，基于refbase的引用计数型指针sptr和wptr配合使用时，存在对RefBase对象重复析构的问题。
测试代码如下，典型的读者写者双线程模型，主线程每帧更新cache_,子线程每帧读取cache，在对成员变量cache_读取的地方都加锁保护。

预期表现：程序不会崩溃，两个线程中各自的sptr在各自退出自己的生命周期之后对Test对象引用计数减一，Test对象自动析构（CPP标准规定，引用计数型指针的线程安全性为：在多线程环境下，每个线程拥有各自的sptr指向同一个对象时，其各自减一次引用计数，能够保证只析构对象一次），屏幕一直刷Test对象的构造函数和析构函数的log，并且sequenceId依次增大；

实际表现：程序出现重复析构Test对象，导致core dump；

补充：将测试用例中的sptr和wptr分别改为标准库的std::shared_ptr和std::weak_ptr，则运行良好，符合预期。

```c++
#include "refbase.h"

#include <mutex>
#include <iostream>
#include <thread>
#include <unistd.h>

using namespace OHOS;

namespace utils {
inline int generateSequenceId()
{
    static std::atomic<int> sequenceId(0);
    return sequenceId.fetch_add(1, std::memory_order_relaxed);
}

inline void writeDebugInfo(const char *info, int id, pid_t tid)
{
    static std::mutex mutex;
    std::lock_guard<std::mutex> lock(mutex);
    std::cout << info << ", id: " << id << ", tid: " << tid << std::endl;
}
} // namesapce utils

class Test : public RefBase {
public:
    Test() : sequenceId_(utils::generateSequenceId())
    {
        utils::writeDebugInfo("Test obj ctor", sequenceId_, gettid());
    }

~Test() noexcept
    {
        utils::writeDebugInfo("Test obj dtor", sequenceId_, gettid());
    }
private:
    int sequenceId_ = -1;
};

class TestRunner {
public:
    void run()
    {
        while (true) {
            {
                std::lock_guard<std::mutex> lock(mutex_);
                wptr<Test> t = cache_;
            }

sptr<Test> newCache(new Test());
            setCache(newCache);
            usleep(100);
        }
    }

void getCache(sptr<Test> &out) const
    {
        std::lock_guard<std::mutex> lock(mutex_);
        out = cache_;
    }

void setCache(const sptr<Test> &cache)
    {
        std::lock_guard<std::mutex> lock(mutex_);
        cache_ = cache;
    }

private:
    mutable std::mutex mutex_;
    sptr<Test> cache_;
};

static void subThreadFunc(TestRunner &testRunner)
{
    while (true) {
        {
            sptr<Test> cache;
            testRunner.getCache(cache);
        }
        usleep(100);
    }
}

int main()
{
    TestRunner t;
    std::thread subThread {[&t]() {
        subThreadFunc(t);
    }};
    subThread.detach();
    t.run();
    return 0;
}
```

```
... ...
Test obj ctor, id: 759, tid: 983755
Test obj dtor, id: 758, tid: 983755
Test obj ctor, id: 760, tid: 983755
Test obj dtor, id: 759, tid: 983755
Test obj ctor, id: 761, tid: 983755
Test obj dtor, id: 760, tid: 983755
Test obj ctor, id: 762, tid: 983755
Test obj dtor, id: 761, tid: 983755
Test obj ctor, id: 763, tid: 983755
Test obj dtor, id: 762, tid: 983755
Test obj ctor, id: 764, tid: 983755
Test obj dtor, id: 763, tid: 983755
Test obj dtor, id: 763, tid: 983756
Segmentation fault (core dumped)
```

类型	指派人员	状态
审查	hhj	进行中 (0/1人)
测试	openharmony_ci	进行中 (0/1人)

OpenHarmony/commonlibrary_c_utils .gitee-modal { width: 500px !important; }

搜索帮助

OpenHarmony/commonlibrary_c_utils