C++多线程场景如何避免子线程打印打乱主线程当前输入行

要实现子线程异步输出时，用户输入行始终固定在终端底部，核心是串行化所有终端IO操作，同时在子线程插入输出时主动重绘输入行，具体实现如下： #

核心依赖 #

• 全局互斥锁：所有线程的终端读写操作必须先持有该锁，彻底避免多线程输出内容穿插错乱。
• 全局输入状态：存储固定输入提示符（如示例中的Input: ）、用户已输入但未提交的半行内容。
• ANSI终端转义序列：用于快速清空行、移动光标，所有主流现代终端（Linux/macOS终端、Windows Terminal、Win10及以上版本CMD）均默认支持，老版本Windows可通过SetConsoleMode开启ENABLE_VIRTUAL_TERMINAL_PROCESSING标志适配。

子线程输出流程 #

子线程每次需要打印内容时严格按以下步骤执行：

1. 持有全局互斥锁
2. 输出转义序列\r\033[K：\r将光标移动到当前行首，\033[K清空光标位置到行尾的所有内容，擦除当前正在显示的未提交输入行
3. 打印子线程待输出的内容，末尾必须加换行符
4. 重新打印输入提示符，再输出全局存储的用户已输入半行内容，光标停在已输入内容末尾，不追加换行
5. 释放全局互斥锁

主线程输入逻辑改造 #

原代码直接用std::getline阻塞读整行的写法无法实时记录用户输入的半行内容，需要改成逐字符读取，实时同步全局输入状态：

1. 循环开始时持有锁，打印初始Input: 提示符，释放锁
2. 逐字符读取标准输入：
   • 读到普通可打印字符：加锁，将字符追加到全局输入缓冲区，同时向终端输出该字符，释放锁
   • 读到退格键（ASCII 127或8）：加锁，若输入缓冲区非空则删除末尾字符，向终端输出\b \b序列擦除最后一个显示的字符，释放锁
   • 读到换行符：加锁，将当前缓冲区内容拷贝为完整输入消息，清空全局输入缓冲区，输出换行后执行消息处理逻辑（如原代码的printf("Message: %s\n", ...)），处理完成后重新打印Input: 提示符，释放锁，等待下一轮输入

原代码问题说明 #

原示例存在逻辑错误：线程创建后立刻调用detach()，后续th.joinable()会永久返回false，外层循环判断完全失效。如果需要控制服务线程生命周期，建议使用std::atomic<bool>作为线程退出标志，不要在创建线程后立刻detach，程序退出前再执行join()回收线程资源。 #

参考实现代码 #

#include <iostream>
#include <thread>
#include <mutex>
#include <string>
#include <chrono>
#include <cstdio>
#include <atomic>

// 全局IO锁
std::mutex io_mtx;
// 全局输入状态
std::string g_input_prompt = "Input: ";
std::string g_current_input;
// 服务线程退出标志
std::atomic<bool> g_server_running{true};

// 线程安全的子线程打印函数
void safe_print(const std::string& msg) {
    std::lock_guard<std::mutex> lock(io_mtx);
    // 清空当前输入行
    printf("\r\033[K");
    // 打印子线程消息
    printf("%s\n", msg.c_str());
    // 重绘输入行
    printf("%s%s", g_input_prompt.c_str(), g_current_input.c_str());
    fflush(stdout);
}

// 服务线程逻辑：不定时打印输出
void server_thread() {
    int count = 0;
    while (g_server_running) {
        std::this_thread::sleep_for(std::chrono::seconds(2));
        safe_print("Server log: count = " + std::to_string(count++));
    }
}

int main() {
    std::thread th(server_thread);

    // 初始打印提示符
    {
        std::lock_guard<std::mutex> lock(io_mtx);
        printf("%s", g_input_prompt.c_str());
        fflush(stdout);
    }

    while (g_server_running) {
        char c = getchar(); 
        std::lock_guard<std::mutex> lock(io_mtx);
        if (c == '\n' || c == EOF) {
            // 提交输入
            std::string message = g_current_input;
            g_current_input.clear();
            printf("\nMessage: %s\n", message.c_str());
            // 退出指令示例：输入exit就停止服务线程
            if (message == "exit") {
                g_server_running = false;
            }
            printf("%s", g_input_prompt.c_str());
            fflush(stdout);
        } else if (c == 127 || c == '\b') {
            // 退格处理
            if (!g_current_input.empty()) {
                g_current_input.pop_back();
                printf("\b \b");
                fflush(stdout);
            }
        } else {
            // 普通字符追加
            g_current_input.push_back(c);
            putchar(c);
            fflush(stdout);
        }
    }

    th.join();
    return 0;
}

注：上述代码默认使用终端行缓冲模式，如果要实现无回车的实时逐字符读取，Linux环境需要修改termios配置关闭行缓冲和回显，Windows环境可直接使用_getch()API实现，不需要修改终端配置。

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