基于ncurses的聊天程序：如何实现每秒刷新界面并同时处理输入？

一、是否需要线程？ #

线程并非必须，但属于可选方案。如果选择线程方案，必须注意ncurses不是线程安全的——所有调用ncurses终端操作函数（比如print_chat、refresh、getch）的代码段，都需要用互斥锁（如pthread_mutex_t）保护，避免多线程同时操作终端导致界面错乱。

二、非线程的更优解决方案 #

无需线程即可实现需求，以下几种方法更简单高效：

方法1：设置非阻塞输入 #

用nodelay将getch()设为非阻塞模式，无输入时直接返回ERR，同时在循环内控制每秒一次的刷新逻辑：

#include <time.h>

int main() {
    // ncurses初始化
    initscr();
    cbreak();
    noecho();
    nodelay(stdscr, TRUE); // 开启非阻塞输入

    time_t last_refresh = time(NULL);
    char chat[BUFSIZ] = "";

    while (1) {
        // 处理用户输入
        int ch = getch();
        if (ch != ERR) {
            if (ch == '\n') {
                // 此处添加发送消息到服务器的逻辑
                // send_message_to_server(input_buffer);
                // 清空输入缓冲区
            } else {
                // 此处添加输入字符拼接逻辑
                // strncat(input_buffer, &ch, 1);
            }
        }

        // 每秒刷新一次界面并拉取新消息
        time_t now = time(NULL);
        if (difftime(now, last_refresh) >= 1) {
            strcpy(chat, read_chat_from_server());
            print_chat(chat);
            refresh();
            last_refresh = now;
        }

        napms(10); // 短暂休眠，降低CPU占用
    }

    endwin();
    return 0;
}

方法2：设置输入超时 #

用timeout给getch()设置等待超时，超时后自动返回ERR，既不会完全阻塞，也能避免循环空转：

int main() {
    initscr();
    cbreak();
    noecho();
    timeout(100); // getch等待100ms后超时返回

    time_t last_refresh = time(NULL);
    char chat[BUFSIZ] = "";

    while (1) {
        int ch = getch();
        if (ch != ERR) {
            // 处理用户输入逻辑
        }

        time_t now = time(NULL);
        if (difftime(now, last_refresh) >= 1) {
            strcpy(chat, read_chat_from_server());
            print_chat(chat);
            refresh();
            last_refresh = now;
        }
    }

    endwin();
    return 0;
}

方法3：用select监听输入与定时 #

如果需要同时监听服务器Socket和终端输入，或需要更精确的定时控制，可以用select实现多路复用：

#include <sys/select.h>
#include <unistd.h>

int main() {
    initscr();
    cbreak();
    noecho();
    nodelay(stdscr, TRUE);
    int stdin_fd = fileno(stdin);

    fd_set read_fds;
    struct timeval tv;

    char chat[BUFSIZ] = "";
    time_t last_refresh = time(NULL);

    while (1) {
        FD_ZERO(&read_fds);
        FD_SET(stdin_fd, &read_fds);

        // 设置select超时100ms
        tv.tv_sec = 0;
        tv.tv_usec = 100000;

        int ret = select(stdin_fd + 1, &read_fds, NULL, NULL, &tv);
        if (ret > 0 && FD_ISSET(stdin_fd, &read_fds)) {
            int ch = getch();
            if (ch != ERR) {
                // 处理用户输入逻辑
            }
        }

        // 每秒拉取新消息并刷新
        time_t now = time(NULL);
        if (difftime(now, last_refresh) >= 1) {
            strcpy(chat, read_chat_from_server());
            print_chat(chat);
            refresh();
            last_refresh = now;
        }
    }

    endwin();
    return 0;
}

三、线程方案的注意事项 #

如果一定要使用线程，核心是用互斥锁保护所有ncurses操作，示例伪代码如下：

#include <pthread.h>

pthread_mutex_t ncurses_mutex;

void* refresh_thread(void* arg) {
    char* chat = arg;
    while (1) {
        sleep(1);
        char* new_chat = read_chat_from_server();
        strcpy(chat, new_chat);

        // 加锁后执行终端刷新
        pthread_mutex_lock(&ncurses_mutex);
        print_chat(chat);
        refresh();
        pthread_mutex_unlock(&ncurses_mutex);
    }
    return NULL;
}

int main() {
    initscr();
    cbreak();
    noecho();
    pthread_mutex_init(&ncurses_mutex, NULL);

    char chat[BUFSIZ] = "";
    pthread_t tid;
    pthread_create(&tid, NULL, refresh_thread, chat);

    while (1) {
        // 加锁后处理输入
        pthread_mutex_lock(&ncurses_mutex);
        int ch = getch();
        pthread_mutex_unlock(&ncurses_mutex);

        if (ch != ERR) {
            // 处理输入并发送到服务器
        }
    }

    pthread_join(tid, NULL);
    pthread_mutex_destroy(&ncurses_mutex);
    endwin();
    return 0;
}

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