c++等待线程退出

Question

我在 Linux 下用 C++ 编写了一个程序。对于线程，我使用的是 pthread。 在程序中，我启动线程并且该线程一直在运行，直到我调用该函数，这应该停止它。在这里你可以看到我的代码。

bool isRunning = false;
pthread_t thread;

void startThread() {
    isRunning = true;
    int thread_return = pthread_create(&thread, NULL, runThread, NULL);
}

bool stopThread() {
    isRunning = false;
    // wait until the thread will be finished
    return true;
}

void* runThread(void* ptr) {
    while(isRunning) {
        // do smth.
    }
    pthread_exit(NULL);
}

当线程启动时，它会做某事。直到isRunning 的值变为false 并且主程序本身将执行其他操作。问题是，当我调用函数stopThread 时，该函数只是将isRunning 设置为false，而不是等到线程在while 循环中完成其任务。 我的问题是，我怎么能说函数stopThread，它应该等待线程退出。

在将isRunning 设置为false 后，我尝试将pthread_join 放入stopThread 函数中。但有时它会导致问题，即程序无限等待。因为线程完成的速度比程序来等待线程快。因为线程可以在while循环内的不同部分。所以我永远不知道线程需要退出多少。

谢谢

Answer 1

根据我对您问题的理解，您应该使用thread joining 的概念。

这样，

bool stopThread() {
    int returnCode;
    isRunning = false;
    void *status;
    rc = pthread_join(your_thread, &status);

    // wait until the thread will be finished

    if (rc) {
        printf("ERROR; return code from pthread_join() 
                is %d\n", rc);
        exit(-1);
    }
    printf("Main: completed join with thread %ld having a status   
            of %ld\n",t,(long)status);

    return true;
}

Answer 2

查看函数pthread_join。 Single UNIX specification documentation for pthread_join.

您需要跟踪线程 ID，才能使用此功能。一个常见的范例似乎是有一个 Thread 类，它封装了这些信息。

Answer 3

在这种情况下，您应该可以对其执行pthread_join()，但如果由于某种原因不起作用，您可以尝试添加hasFinished 变量（然后在您关闭的任何地方等待hasFinished == true线程...）

bool isRunning = false;
pthread_t thread;

// TODO FIX: this is a workaround due to pthread_join() not working properly
bool hasFinished = false

void startThread() {
    isRunning = true;
    int thread_return = pthread_create(&thread, NULL, runThread, NULL);
}

bool stopThread() {
    isRunning = false;
    // wait until the thread will be finished
    return true;
}

void* runThread(void* ptr) {
    while(isRunning) {
        // do smth.
    }

    // TODO FIX: this is a workaround because pthread_join() is not working properly
    hasFinished = true;
    pthread_exit(NULL);

}

[编辑澄清：]

以及在哪里停止线程

/**/
// TODO FIX: this following is a workaround due to pthread_join() not working
isRunning = false;

int TimeoutSleep_ms = 100;
// TimeoutSleep_ms * TimeoutCounter is the timeout time, 10 sec for this case
int TimeoutCounter = 100; 

while (!hasFinished && (--TimeoutCounter > 0))
    sleep(100);
// END TODO FIX
/**/