c++ - 在 C++ 中终止线程的正确方法

Question

我正在学习多线程并编写了这段代码:

#include <iostream>
#include <mutex>
#include <thread>
#include <string>
#include <chrono>
#include <condition_variable>

int distance = 20;
int distanceCovered = 0;
std::condition_variable cv;
std::mutex mu;

void keep_moving(){
  while(true){
  std::cout << "Distance is: " << distanceCovered << std::endl;
  std::this_thread::sleep_for(std::chrono::milliseconds(1000));
  distanceCovered++;
  if(distanceCovered == distance){
    cv.notify_one();
    std::terminate();
   }
 }
}

void wake_me_up()
{
  std::unique_lock<std::mutex> ul(mu);
  cv.wait( ul, []{ return distanceCovered==distance; });   // protects the lines of code below
  std::cout << "I'm here" << std::endl;
  std::terminate();
}

int main() {
  std::thread driver(keep_moving);
  std::thread wake_me(wake_me_up);
  driver.join();
  wake_me.join();

  system("pause");

  return 0;
}

如您所见，线程“keep_moving”在 20 秒内从 0 计数到 20，然后通知打印“我在这里”的“wake_me_up”线程，然后终止。在通知线程后，“keep_moving”线程也终止。

请告诉我是否以正确的方式终止线程。当我运行此代码时，我收到以下消息:

terminate called without an active exception
I'm here
terminate called recursively
Aborted

谢谢。

Answer 1

没有。终止线程的正确(并且仅在标准 C++ 中是正确的)方法是从其线程函数返回。

std::terminate 终止你的整个过程。即使它只是终止了当前线程(即表现得像 Win32 TerminateThread 函数，您应该永远调用!)，它也不会展开堆栈，而不是调用析构函数，因此可能会留下一些未完成的必要清理(如释放互斥量)。

std::terminate 旨在用于您的程序可能无法继续的严重故障。消息“没有事件异常”是因为 terminate 的主要用途是在异常系统失败时终止程序，例如由于嵌套异常，因此该函数默认查找事件异常并打印有关它的信息。