Tkinter调用Popen.communicate发送指令后窗口冻结问题排查

问题描述 #

使用Tkinter实现控制台模拟，执行ping -t google.com并实时输出结果，但按下Ctrl+C调用self.process.communicate(b'\x03')时，窗口冻结，后续代码无法执行。预期发送Ctrl+C后能终止ping进程并显示统计信息。

问题代码 #

import subprocess
import threading
import tkinter as tk

class PingThread(threading.Thread):
    def __init__(self, text_widget):
        super().__init__()
        self.text_widget = text_widget
        self.process = None
        self.stop_event = threading.Event()

    def run(self):
        self.process = subprocess.Popen(['cmd'], stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
        self.process.stdin.write(b'ping -t google.com\n')
        self.process.stdin.flush()

        while not self.stop_event.is_set():
            line = self.process.stdout.readline().decode('cp866')
            if not line:
                break
            self.text_widget.insert(tk.END, line)
            self.text_widget.see(tk.END)

    def stop(self):
        if self.process:
            self.process.communicate(b'\x03')
            self.process.wait()                                #Window freezes on the .communicate line, so this and line below are not executing at all
        self.stop_event.set()

def ping():
    ping_thread = PingThread(text)
    ping_thread.start()

    def handle_ctrl_c(event):
        ping_thread.stop()
        text.insert(tk.END, '\nProcess terminated.\n')

    root.bind('<Control-c>', handle_ctrl_c)

root = tk.Tk()

text = tk.Text(root)
text.pack()

button = tk.Button(root, text='Ping', command=ping)
button.pack()

root.mainloop()

成因分析 #

1. communicate()的阻塞特性：communicate()是阻塞方法，会等待进程结束并读取所有stdout/stderr直到EOF。而PingThread子线程正在循环读取stdout，处理Tkinter事件的主线程调用communicate()后，会和子线程争抢stdout的读取权限，导致死锁，窗口因此冻结。
2. 多线程资源冲突：子线程持续持有stdout句柄进行读取，主线程的communicate()无法获取完整输出，双方互相等待，最终导致程序无响应。

解决方案 #

核心修改点 #

• 移除communicate()，改为直接向cmd进程发送Ctrl+C信号（\x03），并通过停止事件让子线程自行处理进程结束后的输出。
• 优化子线程的输出读取逻辑，确保进程终止后能读取剩余的统计信息。
• 避免重复绑定Ctrl+C事件，防止多次触发。

修改后的代码 #

import subprocess
import threading
import tkinter as tk

class PingThread(threading.Thread):
    def __init__(self, text_widget):
        super().__init__()
        self.text_widget = text_widget
        self.process = None
        self.stop_event = threading.Event()

    def run(self):
        self.process = subprocess.Popen(
            ['cmd'], 
            stdin=subprocess.PIPE, 
            stdout=subprocess.PIPE, 
            stderr=subprocess.PIPE, 
            shell=True,
            creationflags=subprocess.CREATE_NEW_PROCESS_GROUP  # 创建新进程组，确保信号正确传递
        )
        self.process.stdin.write(b'ping -t google.com\n')
        self.process.stdin.flush()

        # 循环读取输出，直到停止事件触发或进程结束
        while True:
            if self.stop_event.is_set():
                break
            line = self.process.stdout.readline().decode('cp866')
            if not line:
                break
            # 委托主线程处理UI更新，避免子线程直接操作UI引发异常
            self.text_widget.after(0, lambda l=line: self.text_widget.insert(tk.END, l))
            self.text_widget.after(0, self.text_widget.see, tk.END)
        
        # 读取进程结束后的剩余统计信息
        remaining_output = self.process.stdout.read().decode('cp866')
        if remaining_output:
            self.text_widget.after(0, lambda ro=remaining_output: self.text_widget.insert(tk.END, ro))
        
        # 等待进程完全结束
        if self.process:
            self.process.wait()

    def stop(self):
        if self.process and self.process.poll() is None:  # 检查进程是否仍在运行
            # 向cmd发送Ctrl+C信号
            self.process.stdin.write(b'\x03')
            self.process.stdin.flush()
        # 设置停止事件，让子线程退出循环
        self.stop_event.set()

def ping():
    global ping_thread
    ping_thread = PingThread(text)
    ping_thread.start()

    # 先解绑之前的绑定，避免重复触发终止逻辑
    root.unbind('<Control-c>')
    def handle_ctrl_c(event):
        ping_thread.stop()
        text.insert(tk.END, '\nProcess terminated.\n')

    root.bind('<Control-c>', handle_ctrl_c)

root = tk.Tk()
root.title("Ping Console")

text = tk.Text(root)
text.pack(fill=tk.BOTH, expand=True)

button = tk.Button(root, text='Start Ping', command=ping)
button.pack(pady=5)

root.mainloop()

关键优化说明 #

1. 替换communicate()：直接通过stdin.write(b'\x03')发送Ctrl+C信号，避免主线程阻塞。
2. 新进程组创建：添加creationflags=subprocess.CREATE_NEW_PROCESS_GROUP，确保信号能正确传递给ping子进程。
3. UI操作规范：使用after(0, ...)将UI更新操作委托给Tkinter主线程，符合Tkinter的线程安全要求。
4. 剩余输出读取：进程终止后读取剩余的统计信息，确保完整显示ping结果。
5. 事件绑定优化：每次启动ping前解绑之前的Ctrl+C绑定，防止多次触发终止逻辑。

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