C++ 终止线程

Question

我知道这个问题已被多次询问和回答，并且我知道结束线程的最佳方法是使用标志并在请求时退出线程函数。这也是我目前正在做的，但是我的问题是线程函数运行的时间很长，所以有时我需要等待几个小时，直到线程结束。我的线程函数看起来像这样：

void threadfunction()
{
    while(!exitRequested)
    {
        doSomeWork();
        object1.doSomeWork();
        object2.doSomeWork();
        while(somecondition)
        {
            object3.doSomeWork();
        }
        object4.doSomeWork();
    }
}

这只是一个示例，实际上代码看起来要复杂得多。但我想演示的是，我调用了几个类方法，这些方法可能需要几个小时才能完成（每个函数）。

所以我现在正在做的是检查函数之间是否请求退出（例如在object1.doSomeWork(); 和object2.doSomeWork(); 之间）但是正如我所说的函数调用可能需要几个小时，所以我需要检查是否在这些功能中要求退出。为了做到这一点，我需要将exitRequested 标志传递给这些函数，但在我看来这看起来不太好，可能有更好的解决方案。

我能想到的一个解决方案是通过抛出异常来创建这样的东西：

void threadfunction()
{
    try {
        while(!exitRequested)
        {
            ...
        }
    } catch (const ExitRequestException &e) {}
}

但是需要以某种方式引发异常。据我所知，我不能在另一个线程的线程中引发异常，对吧？

您有更好的解决方案吗？还是您认为我真的需要将exitRequested 标志传递给所有这些函数并污染我的代码？

Answer 1

在谷歌搜索了一段时间后，我发现（并创建了）一个对我来说非常好的答案，尽管它只适用于 pthreads。对于非 pthread，我可以想象使用 here 描述的概念。

那么我现在在做什么：我正在向工作线程发送信号。此线程在信号处理程序中处理自定义信号并引发异常。此异常出现在线程函数的外部。通过使用这个概念，我的优势是抛出异常并展开堆栈，因此我可以关闭所有打开的资源。这是我的完整工作示例：

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

using namespace std;

//Custom exception which is used to stop the thread
class StopException {};

void sig_fun(int s)
{
    if(s == SIGUSR2)throw StopException();
}

void threadFunction()
{
    cout<<"Thread started"<<endl;
    try {
        while(true)
        {
            //Work forever...
            sleep(1);
        }
    } catch(const StopException &e) {
        cout<<"Thread interrupted"<<endl;
    }
    cout<<"Thread stopped"<<endl;
}

int main(int argc, char *args[])
{
    //Install Signal handler function
    signal(SIGUSR2, sig_fun);
    pthread_t threadObject;
    thread t([&threadObject]()
    {
        //Store pthread_t object to be able to use it later
        threadObject = pthread_self();
        threadFunction();
    });

    string temp;
    cout<<"Write something when you want the thread to be killed"<<endl;
    cin>>temp;

    //Send Signal to thread
    pthread_kill(threadObject, SIGUSR2);
    t.join();
}