C++线程在加入后不能中止

Question

所以我的程序中有 2 个线程在运行，我最终希望它们在调用此函数时终止：

void AutoClicker::TerminateThreads()
{
    programrunning = false;
    clicker.join();
    hotkeyLoop.join();
    terminateThread = true;
}

然后调用线程应该运行这段代码：

while (1)
{
    while (programrunning)
    {
        mouse_event(MOUSEEVENTF_LEFTDOWN, 0, 0, 0, 0);
        mouse_event(MOUSEEVENTF_LEFTUP, 0, 0, 0, 0);
        std::this_thread::sleep_for(std::chrono::milliseconds(delay));
    }

    if (terminateThread) {
        std::terminate();
    }
    std::this_thread::sleep_for(std::chrono::milliseconds(200));
}

但最后一个if 语句似乎没有被调用。它位于我试图终止的线程内，所以它应该可以正常工作吗？我对线程很陌生，所以我真的不知道该怎么做，但这是我在网上找到的：

“当std::thread 对象被销毁时，它不允许被joinable()，即在它被销毁之前必须发生两件事之一：

它被分离了，线程已经进入野外，几乎无法控制它是否完成。

话题已经join()ed。"

Answer 1

从两件事开始：

• 请勿致电std::terminate()。这不是拆除程序的好方法，并且可能会使打开的文件和其他操作系统资源挂起。此外，它适用于您的整个程序，而不仅仅是您调用它的线程。
• 如果您希望 std::thread 终止，则只需从它返回或让它到达线程函数的末尾。

除此之外，这是一个小程序，展示了我将如何执行您所描述的操作：

#include <iostream>
#include <atomic>
#include <chrono>
#include <thread>

void threadfunc(std::atomic<bool>& running)
{
    while (running) {
        std::cout << "beep\n";
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

void waitThread(std::atomic<bool>& running)
{
    std::this_thread::sleep_for(std::chrono::seconds(10));
    running = false;
}

int main()
{
    std::atomic<bool> running = true;

    std::thread t1(threadfunc, std::ref(running));
    std::thread t2(waitThread, std::ref(running));
    t1.join();
    t2.join();
}

希望您可以在这里收集一些信息以使您的程序正常运行。

编辑： 从 OP 对另一个答案的评论中澄清一些内容：

类似：std::thread t1(threadfunc, std::ref(running)); 创建一个执行所提供函数的活动线程。一旦该函数停止（返回），线程就会处于僵尸状态，它不会执行但仍处于活动状态并持有资源。

https://en.cppreference.com/w/cpp/thread/thread/joinable

已完成执行代码但尚未加入的线程 仍然被认为是一个活动的执行线程，因此是 可加入。

为了将线程从僵尸状态中拉出来并清理它的资源，你必须在它上面调用join()。请注意，您可以在该线程执行之前或之后在该线程上调用join() - 如果您之前加入，您会阻塞直到加入的线程完成，如果您之后加入，则清理延迟线程并立即继续。

或者，您可以在线程上调用detach()：

https://en.cppreference.com/w/cpp/thread/thread/detach

将执行线程与线程对象分开，允许 执行以独立继续。任何分配的资源将 线程退出后释放。

但是一旦你分离了一个线程，你就不能再加入它，并且在仍然有活动但分离的线程运行时让你的主线程退出会以一种不太好的方式杀死分离的线程。因此，只有在您确定分离的线程将在主线程之前完成时才这样做。

Answer 2

你并没有真正拥有这里的所有代码，但我猜点击器线程中的方法可能看起来像

void clickerThreadFunction()
{
  while(programrunning)
  {
    // do stuff
  }

  if (terminateThread)
  {
    std::terminate();
  }
}

如果是这样，那就看代码

programrunning = false;
clicker.join();

第一行将导致点击器线程中的while 循环退出。 clicker 方法的其余部分将运行，包括 if (terminateThread) 检查，该检查将失败，因为您尚未将 terminateThread 设置为 true。只有这样，一旦我们到达clickerThreadFunction 的底部，clicker.join() 才会返回，因为std::thread::join 等待线程完成然后返回控制权。

无论如何，我不清楚您要在这里做什么。 std::terminate 的目的是立即使程序崩溃。如果您希望发生这种情况，则不清楚您为什么要打扰加入线程，因为无论如何您都不会到达那部分。

Answer 3

你知道join 做什么吗？ join 等待线程完成。

您的 TerminateThreads 函数将 programrunning 设置为 false，然后等待线程完成，然后将 terminateThread 设置为 true。

线程一直运行直到 terminateThread 变为 true，因此当 TerminateThreads 函数被调用时，它永远不会到达将 terminateThread 设置为 true 的部分，因为它正在等待线程完成。