并发程序中如何避免用户输入与服务器消息展示冲突？

这个问题我之前做聊天室类程序时也踩过坑，终端的共享IO确实很容易导致输入和消息混在一起，核心原因就是默认的cin是阻塞式的，而且终端没有区分输入区和输出区，后台线程突然打印消息时会直接插入到用户正在敲的文本里。下面给你几个实用的解决思路：

1. 改用非阻塞式输入（推荐） #

通过修改终端属性，把阻塞的cin改成非阻塞模式，这样可以定期检查用户输入，同时不耽误处理服务器消息，而且打印消息时可以主动规避输入行。

这里给你一个C++的实现示例：

#include <iostream>
#include <thread>
#include <termios.h>
#include <unistd.h>
#include <fcntl.h>
#include <chrono>

// 切换终端的非阻塞输入模式
void set_non_blocking(bool enable) {
    termios tty;
    tcgetattr(STDIN_FILENO, &tty);
    
    if (enable) {
        // 关闭规范模式（不用等回车触发输入）
        tty.c_lflag &= ~ICANON;
        // 最小读取字符数设为0，超时设为0
        tty.c_cc[VMIN] = 0;
        tty.c_cc[VTIME] = 0;
    } else {
        // 恢复默认模式
        tty.c_lflag |= ICANON;
        tty.c_cc[VMIN] = 1;
        tty.c_cc[VTIME] = 0;
    }
    tcsetattr(STDIN_FILENO, TCSANOW, &tty);

    // 设置文件描述符为非阻塞
    int flags = fcntl(STDIN_FILENO, F_GETFL, 0);
    fcntl(STDIN_FILENO, F_SETFL, enable ? (flags | O_NONBLOCK) : (flags & ~O_NONBLOCK));
}

// 模拟监听服务器消息的线程
void listen_server() {
    while (true) {
        std::this_thread::sleep_for(std::chrono::seconds(2));
        // 打印消息前先换行，避开当前输入行
        std::cout << "\n[Server] 收到新消息：Hello from server!" << std::endl;
        // 重新提示用户输入，让光标回到输入区
        std::cout << "请输入命令: ";
        std::cout.flush(); // 确保输出立即显示
    }
}

int main() {
    set_non_blocking(true);
    std::thread listener(listen_server);
    listener.detach();

    std::string input;
    char c;
    std::cout << "请输入命令: ";
    std::cout.flush();

    while (true) {
        // 逐个读取输入字符
        while (read(STDIN_FILENO, &c, 1) > 0) {
            if (c == '\n') {
                // 用户输入完成，处理命令
                std::cout << "\n你输入的命令是: " << input << std::endl;
                input.clear();
                std::cout << "请输入命令: ";
                std::cout.flush();
            } else if (c == 127) { // 处理退格键
                if (!input.empty()) {
                    input.pop_back();
                    // 清除终端上的退格痕迹
                    std::cout << "\b \b";
                    std::cout.flush();
                }
            } else {
                input += c;
                std::cout << c;
                std::cout.flush();
            }
        }
        // 短暂休眠，避免占用过多CPU
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }

    set_non_blocking(false);
    return 0;
}

这个方案的优势是消息实时显示，同时不会干扰用户输入，缺点是需要手动处理终端属性和输入字符（比如退格、回车）。

2. 使用终端UI库（比如ncurses） #

如果不想自己折腾终端属性，可以用专门的终端窗口库，比如ncurses。它可以把终端分成多个独立窗口，比如上方显示服务器消息，下方固定为输入区域，两者完全隔离，不会出现混乱。

大致实现思路：

• 初始化ncurses环境
• 创建两个窗口：一个用于输出服务器消息，一个用于接收用户输入
• 监听线程往消息窗口追加内容，主线程在输入窗口处理用户输入
• 定期刷新窗口，确保内容实时显示

这种方案适合复杂的终端交互场景，代码结构更清晰，但需要学习ncurses的基本用法。

3. 缓存服务器消息，在输入间隙显示 #

如果对消息实时性要求不高，可以用一个队列缓存服务器消息，等用户输入完成（比如cin返回后）再批量打印缓存的消息。

示例代码：

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

std::queue<std::string> msg_queue;
std::mutex mtx;
std::condition_variable cv;
bool running = true;

void listen_server() {
    while (running) {
        std::this_thread::sleep_for(std::chrono::seconds(2));
        std::lock_guard<std::mutex> lock(mtx);
        msg_queue.push("[Server] 新消息来了！");
        cv.notify_one();
    }
}

void print_pending_msgs() {
    std::lock_guard<std::mutex> lock(mtx);
    while (!msg_queue.empty()) {
        std::cout << msg_queue.front() << std::endl;
        msg_queue.pop();
    }
}

int main() {
    std::thread listener(listen_server);
    listener.detach();

    std::string input;
    while (true) {
        std::cout << "请输入命令: ";
        std::getline(std::cin, input);
        
        // 输入完成后打印所有缓存的服务器消息
        print_pending_msgs();
        
        std::cout << "处理命令: " << input << std::endl;
        if (input == "quit") {
            running = false;
            break;
        }
    }

    return 0;
}

这个方案实现最简单，但消息不是实时显示的，必须等用户输入完才能看到新消息，适合对实时性要求低的场景。

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