如何安全地终止线程？ （使用指针）C++

Posted 2023-02-17

【中文标题】如何安全地终止线程？ （使用指针）C++

【英文标题】：How to terminate a thread safely? (with the usage of pointer) c++

【发布时间】：2019-10-19 06:16:17

【问题描述】：

我目前正在学习 c++11 中的多线程，我对安全终止线程的方式感到困惑。

在 c++ 中，我知道如何创建线程并使用 thread.join() 来安全地确保 main() 在退出之前等待所有线程完成。

但是，我发现一些通过指针实现的多线程代码即使不使用 thread.join() 也能够运行。

class Greating

public:

    Greating(const int& _i):i_(_i)
    ~Greating()
    int i_;
    void say()
    
        std::cout << "Hello World" << i_ << std::endl;
    

;

int main()
    Greating greating1(1);
    Greating greating2(2);

    std::thread t1(&Greating::say, greating1);
    std::thread t2(&Greating::say, greating2);
    return 0;

上面显示的代码绝对会报错"terminate called without an active exception Aborted (core dumped)”，因为我没有使用 t1.join() 和 t2.join()。

但是我在一些代码中发现当他们使用指针来管理线程时，这并没有成为问题，如下图。

class Greating

public:

    Greating(const int& _i):i_(_i)
    ~Greating()
    int i_;
    void say()
    
        std::cout << "Hello World" << i_ << std::endl;
    

;

int main()
    Greating greating1(1);
    Greating greating2(2);

    std::thread* tt1 = new std::thread(&Greating::say, greating1);
    std::thread* tt2 = new std::thread(&Greating::say, greating2);
    return 0;

输出是：

Hello WorldHello World12
Hello World12

没有报告错误。这让我很困惑。

所以我的问题是：

为什么当我们使用指针管理线程时，不能使用函数thread.join()？ 如何正确终止线程？ （可能要等待可调用函数完成？）

非常感谢！

【问题讨论】：

对指针的大切换有以下效果：泄漏线程对象。否则，线程对象将在没有加入或分离的情况下被销毁。因此，只有第一个案例报告该错误才有意义。

【参考方案1】：

使用动态分配创建对象时，您必须使用operator delete 释放内存，以便它调用适当的析构函数。

在第一个示例中，创建了两个 std::thread 对象。在main函数结束时，析构函数std::thread::~thread被调用。由于线程没有join，所以析构函数报错。

另一方面，在第二个示例中，您调用了operator new，因此您创建了具有动态分配的对象。但是，你没有调用operator delete，所以没有调用析构函数。也就是说，程序没有检查线程是否加入。

因此，正确终止线程的唯一方法是调用std::thread::join。如果你想使用指针，你必须这样做：

std::thread *th = new std::thread(foo);
...
th->join();
delete th;