如何从自身加入 std::thread（在 C++11 中）

Question

我有一个 std::thread 正在等待并从套接字读取。并且有一个指向此thread 的指针存储在某处。但是当发生不好的事情并且thread 结束时，我希望它调用一些导致加入该线程的函数，然后删除引用它的指针。 （我可以从线程内访问该指针）

我可以在另一个线程中执行此操作，但新线程成为问题。

Answer 1

您可以在分离状态下创建线程，并使您的线程生命周期依赖于条件变量并在完成时切换布尔状态。

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

class A {
    private:
        void Threadfunction();
        volatile bool class_running;
        volatile bool thread_running;
        std::condition_variable cv;
        std::mutex mu;
    public:
        A();
        ~A();
        void Stop();
};
A::A(){
    class_running = true;
    thread_running = false;
    std::thread t(&A::Threadfunction,this);
    t.detach();
}
A::~A(){
    if(class_running) {this->Stop();}
}
void A::Stop() {
    std::unique_lock<std::mutex> lk(mu);
    class_running = false;
    while(thread_running) {
        cv.wait(lk);
    }
    std::cout << "Stop ended " << std::endl;
}
void A::Threadfunction(){
    thread_running = true;
    std::cout << "thread started " << std::endl;
    while(class_running){
        // Do something
    }
    thread_running = false;
    cv.notify_one();
    std::cout << "thread stopped " << std::endl;
}
int main(){
    A a1;
    A a2;
    sleep(1);
    std::cout << "a1.Stop() called " << std::endl;
    a1.Stop();
    sleep(1);
    std::cout << "a2.Stop() not called but a2 goes out of scope and destructor is called " << std::endl;
}

Answer 2

改变你的设计，这样你就没有这个奇怪的要求了。一个简单的解决方案是将shared_ptrs 用于拥有线程并具有其他状态信息的控制结构。线程可以为这个控制结构持有一个shared_ptr，并使用它来向任何其他感兴趣的代码报告它的状态。当没有人再关心这个线程时，这个控制结构的最后一个shared_ptr 将消失并被销毁。