自终止线程。使用加入或分离

Question

我有一个在 std::thread 中处理的状态机。该状态机初始化网络连接，处理数据，并在收到特定消息后，需要自行关闭。以这种方式使用 join 会触发“已调用 abort()”异常。这是适合分离线程的情况之一吗？

#include <iostream>

#include <thread>
#include <atomic>
#include <memory>

class ThreadExample
{
public:
    ThreadExample()
    {
        StartThread();
    }

    void StartThread()
    {
        //start thread;
        run_thread = true;
        the_thread = std::thread(&ThreadExample::ThreadFunction, this);
    }

    void ThreadFunction()
    {
        while (run_thread)
        {
            if (correct_message_found)
                ShutdownThread();
            else
                ProcessMessage();   //example code to imitate network processing

            //arbitrary wait. not relevant to the problem
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
    }

    //read in by some network connection
    void ProcessMessage(/*some message data*/)
    {
        static int counter = 0;
        if (counter == 3)
        {
            correct_message_found = true;
        }
        else
        {
            std::cout << "Waiting for the right message\n";
            counter++;
        }
    }

    void ShutdownThread()
    {
        run_thread = false;
        if (the_thread.joinable())
            the_thread.join();
    }

private:
    std::thread the_thread;
    std::atomic_bool run_thread;
    bool correct_message_found = false;
};

int main()
{
    auto example = std::make_unique<ThreadExample>();

    int data;
    std::cin >> data;
}

Answer 1

从内部终止线程的正确方法是简单地从线程正在执行的函数中返回：

void ThreadFunction()
{
    while (run_thread)
    {
        if (correct_message_found)
            return;
        else
            ProcessMessage();   //example code to imitate network processing

        //arbitrary wait. not relevant to the problem
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

从应该加入的线程中调用join是一个错误，请参阅第一个错误条件：https://en.cppreference.com/w/cpp/thread/thread/join

join 表示“等待给定线程完成，然后继续”。你是在告诉一个线程等到它自己完成。所以它只能在已经结束的时候结束，这显然是矛盾的。

您应该调用join 的位置在ThreadExample 的析构函数中。 ThreadFunction 使用ThreadExample 的成员，而ThreadExample 也拥有std::thread 对象，因此不能允许ThreadExample 在线程仍在运行时死亡。在你展示的代码中，如果你在线程完成之前输入一些东西，你会遇到这个问题：ThreadExample 然后被销毁，std::thread 对象就在里面。如果 std::thread 在可连接时被销毁（即非分离线程仍在运行），则调用 std::terminate：
https://en.cppreference.com/w/cpp/thread/thread/%7Ethread