C++主线程与子线程终止线程：std::cin.get()失效问题

1. 主线程未正确等待子线程，导致子线程被提前终止 #

如果你的代码结构是主线程启动循环线程后，直接调用std::cin.get()，输入后修改keepRunning但未调用std::thread::join()或detach()，那么当主线程执行到return 0时，会触发std::terminate()，直接终止所有未完成的子线程。你根本看不到循环线程停止的过程，误以为程序“无反应”。

错误代码示例：

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

std::atomic<bool> keepRunning(true);

void loopTask() {
    while (keepRunning) {
        std::cout << "Running..." << std::endl;
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

int main() {
    std::thread loopThread(loopTask);
    
    // 主线程阻塞等待输入
    std::cin.get();
    keepRunning = false;
    
    // 未调用loopThread.join()！
    return 0;
}

输入回车后，主线程设置keepRunning为false随即退出main函数，此时循环线程可能还没检测到变量变化就被强制终止，因此你看不到预期的停止行为。

而把std::cin.get()放到独立线程时，主线程可以正常调用join()等待两个子线程完成，进程不会被提前终止，因此能看到预期效果。

2. 循环线程启动时机错误 #

如果你的代码是主线程先调用std::cin.get()，再启动循环线程，那么在你输入回车之前，循环线程根本没有被创建和启动，自然看不到任何循环行为，表现为“无反应”。

错误代码示例：

int main() {
    // 先阻塞等待输入，循环线程未启动
    std::cin.get();
    std::thread loopThread(loopTask);
    keepRunning = false;
    loopThread.join();
    return 0;
}

这种情况下，程序启动后直接卡在输入等待，循环线程完全没运行，当然没有任何反应。

3. 标准输出缓冲的影响（次要原因） #

如果循环线程中频繁输出到std::cout，而主线程阻塞在std::cin.get()，可能因为标准输出的缓冲未刷新，导致你看不到循环线程的输出，误以为程序没运行。此时可以在循环输出后加上std::cout.flush()强制刷新缓冲。

将输入逻辑放主线程的正确写法：

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

std::atomic<bool> keepRunning(true);

void loopTask() {
    while (keepRunning) {
        std::cout << "Thread is running..." << std::endl;
        std::cout.flush(); // 强制刷新输出缓冲
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
    std::cout << "Thread stopped." << std::endl;
}

int main() {
    std::thread loopThread(loopTask);
    
    std::cin.get();
    keepRunning = false;
    
    // 必须等待循环线程结束
    loopThread.join();
    
    return 0;
}

或者使用双线程的写法：

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

std::atomic<bool> keepRunning(true);

void loopTask() {
    while (keepRunning) {
        std::cout << "Thread is running..." << std::endl;
        std::cout.flush();
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
    std::cout << "Thread stopped." << std::endl;
}

void inputTask() {
    std::cin.get();
    keepRunning = false;
}

int main() {
    std::thread loopThread(loopTask);
    std::thread inputThread(inputTask);
    
    loopThread.join();
    inputThread.join();
    
    return 0;
}

内容的提问来源于stack exchange，提问作者Silviculturalist