如何用Python实现终端类聊天式同步输入输出，避免内容干扰？

我希望用Python实现终端中的同步输入输出（类似聊天场景）：一个线程从上到下向终端输出文本，另一个线程在终端最底部接收用户输入，且不会干扰输出流。

预期效果：终端持续从上到下打印消息，用户始终能在底部输入框输入内容，新输出不会覆盖输入框或已输入的内容。

我尝试了最直观的实现方式：

import threading, time

def output_proc():
    while True:
        print("Some output")
        time.sleep(1)

output_thread = threading.Thread(target = output_proc)
output_thread.start()

while True:
    print(input())

但该代码无法正常工作：程序输出会覆盖用户输入，且输入位置不符合要求。请问最优实现方式是什么？

方案一：使用标准库 curses（无需额外安装） #

curses 是Python内置的终端控制库，可直接操控终端窗口实现分区显示。核心思路是将终端划分为上方输出区和底部输入区，输出仅更新上方区域，输入区固定在底部不被干扰。

示例代码：

import curses
import threading
import time

def output_worker(stdscr, output_lines):
    """生成输出的线程函数"""
    while True:
        time.sleep(1)
        # 添加带时间戳的新输出
        output_lines.append(f"[{time.strftime('%H:%M:%S')}] 系统消息：Some output")
        # 触发窗口刷新
        stdscr.noutrefresh()
        curses.doupdate()

def main(stdscr):
    # 终端初始化
    curses.curs_set(1)  # 显示光标
    stdscr.clear()
    height, width = stdscr.getmaxyx()
    input_win_height = 1
    output_win_height = height - input_win_height

    # 创建分区窗口
    output_win = curses.newwin(output_win_height, width, 0, 0)
    input_win = curses.newwin(input_win_height, width, output_win_height, 0)
    input_win.addstr(0, 0, "> ")
    input_win.refresh()

    output_lines = []

    # 启动输出线程（后台守护线程）
    threading.Thread(target=output_worker, args=(stdscr, output_lines), daemon=True).start()

    while True:
        # 更新输出窗口：只显示能容纳的最新内容
        output_win.clear()
        start_idx = max(0, len(output_lines) - output_win_height)
        for line_idx, content in enumerate(output_lines[start_idx:]):
            if line_idx >= output_win_height:
                break
            output_win.addstr(line_idx, 0, content[:width-1])  # 避免超出终端宽度
        output_win.refresh()

        # 处理用户输入
        input_win.move(0, 2)
        input_win.clrtoeol()
        curses.echo()  # 开启输入回显
        user_input = input_win.getstr(0, 2, width-2).decode('utf-8')
        curses.noecho()
        if user_input.strip():
            output_lines.append(f"你：{user_input}")
        # 重置输入提示符
        input_win.addstr(0, 0, "> ")
        input_win.refresh()

if __name__ == "__main__":
    curses.wrapper(main)

关键说明： #

• curses.wrapper 自动处理窗口初始化、异常清理，避免终端崩溃
• 分区窗口实现输出与输入的物理隔离，彻底解决内容覆盖问题
• 输出线程仅负责生成消息，主循环统一处理窗口刷新，保证线程安全

方案二：使用第三方库 prompt_toolkit（更简洁） #

prompt_toolkit 是专门优化终端输入的库，内置异步输出同步机制，API更友好，无需手动处理窗口分区。

步骤1：安装库 #

pip install prompt_toolkit

示例代码： #

import threading
import time
from prompt_toolkit import PromptSession
from prompt_toolkit.patch_stdout import patch_stdout

def output_worker():
    """后台输出线程"""
    while True:
        time.sleep(1)
        print(f"[{time.strftime('%H:%M:%S')}] 系统消息：Some output")

def main():
    session = PromptSession()
    # 启动输出线程
    threading.Thread(target=output_worker, daemon=True).start()

    # 自动处理输出与输入的同步
    with patch_stdout():
        while True:
            user_input = session.prompt("> ")
            print(f"你：{user_input}")

if __name__ == "__main__":
    main()

关键说明： #

• patch_stdout() 上下文管理器会自动重定向输出，确保新消息插入到输入框上方，不会覆盖输入内容
• PromptSession 支持输入历史记录、自动补全等扩展功能，适合聊天场景迭代优化

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