thread_specific_ptr多线程混淆

thread_specific_ptr multithread confusion

本文关键字：多线程 ptr specific thread      更新时间：2023-10-16

//代码片段 1

static boost::thread_specific_ptr<StreamX> StreamThreadSpecificPtr;
void thread_proc() {
    StreamX * stream = NULL;
    stream = StreamThreadSpecificPtr.get();
    if (NULL == stream) {
        stream = new StreamX();
        StreamThreadSpecificPtr.reset(stream);
    }
    printf("%pn", stream);
}
int run() {
    boost::thread_group threads;
    for(int i = 0; i < 5; i ++) {
        threads.create_thread(&thread_proc);
    }
    threads.join_all();
}
// the result is 
0x50d560  -- SAME POINTER
0x50d540
0x50bfc0
0x50bef0
0x50d560  -- SAME POINTER

代码片段 2

static boost::thread_specific_ptr<StreamX> StreamThreadSpecificPtr(NULL); // DIFF from code snippet 1
void thread_proc() {
    StreamX * stream = NULL;
    stream = StreamThreadSpecificPtr.get();
    if (NULL == stream) {
        stream = new StreamX();
        StreamThreadSpecificPtr.reset(stream);
    }
    printf("%pn", stream);
}
int run() {
    boost::thread_group threads;
    for(int i = 0; i < 5; i ++) {
        threads.create_thread(&thread_proc);
    }
    threads.join_all();
}
// the result is
0x50d510
0x50d4f0
0x50bf70
0x50ca70
0x50be50

在代码段 1 中，两个指针是相同的。 这是意料之中的。在代码片段 2 中，将 StreamThreadSpecificPtr 初始化为 NULL，一切都很好。

你能帮忙找出这个困惑的答案吗？多谢。

令人高兴的是，您的线程实际上是异步终止的，从而破坏了 StreamX 实例。

使用检测器：

struct StreamX
{
    StreamX() { puts(__FUNCTION__); }
   ~StreamX() { puts(__FUNCTION__); }
};

我得到以下输出：

StreamX
0x7f258c0008c0
~StreamX
StreamX
0x7f25740008c0
~StreamX
StreamX
0x7f25840008c0
~StreamX
StreamX
0x7f25780008c0
StreamX
~StreamX
0x7f257c0008c0
~StreamX
real    0m0.002s
user    0m0.000s
sys 0m0.004s

后续分配重用相同的堆地址是有意义的，因为不涉及太多碎片。换句话说，您不能只比较指针以查看它们是否在并发应用程序中为同一对象设置别名。

与第二个示例的区别只是虚假的。有许多因素可以 - 并且将 - 影响结果。例如，在每个线程的末尾添加一个微小的延迟将消除线程在其他实例实例化之前终止的所有机会。

在科里鲁现场观看

相关文章：