使用multiprocessing遇EOFError，线程模式可正常捕获挖矿进程输出

1. Tkinter控件跨进程访问不支持：你的capture_output函数直接操作了self.output_text（Tkinter的Text控件），但Tkinter是单进程设计，不允许跨进程访问GUI控件，这会触发底层资源访问异常，进而导致EOFError。
2. 共享状态未正确处理：如果settings是普通字典，multiprocessing子进程会创建它的独立副本，子进程对settings["mining"]的修改不会同步到父进程，直接读取还可能引发同步问题。
3. 跨进程上下文隔离导致输出读取异常：subprocess的输出捕获逻辑在子进程中执行时，由于进程间的上下文隔离，可能导致stdout读取失败，抛出EOF错误。

核心思路是让主进程（UI线程）负责所有GUI操作，子进程只处理挖矿和输出收集，通过进程间通信传递数据，同时用共享状态控制挖矿启停：

• 用multiprocessing.Queue实现子进程到主进程的输出传递
• 用multiprocessing.Manager创建可跨进程共享的settings字典
• 主进程启动专用线程监听队列、更新UI（Tkinter要求UI操作必须在主线程执行）
• 子进程仅负责执行挖矿命令、捕获输出并发送到队列，同时检查共享状态终止挖矿

import multiprocessing
import threading
import subprocess
import tkinter as tk
from multiprocessing import Manager

class MinerGUI:
    def __init__(self):
        # 初始化UI组件（省略原有代码）
        self.mining_process = None
        self.output_queue = multiprocessing.Queue()
        # 创建跨进程共享的settings字典
        self.settings = Manager().dict()
        self.settings["mining"] = False
        # 启动UI更新守护线程
        self.update_ui_thread = threading.Thread(target=self.update_output_ui, daemon=True)
        self.update_ui_thread.start()

    def update_output_ui(self):
        """主进程线程：监听队列并更新UI"""
        while True:
            try:
                line = self.output_queue.get(timeout=0.1)
                if line is None:  # 子进程发送的结束信号
                    break
                self.output_text.insert(tk.END, line)
                self.output_text.see(tk.END)
            except multiprocessing.queues.Empty:
                continue

    def capture_output(self, mining_command, output_queue, settings):
        """子进程执行函数：仅负责挖矿和输出传递"""
        process = subprocess.Popen(
            mining_command,
            stdout=subprocess.PIPE,
            stderr=subprocess.STDOUT,
            shell=True,
            text=True
        )
        for line in process.stdout:
            output_queue.put(line)
            # 检查停止信号
            if not settings.get("mining", False):
                process.terminate()  # 主动终止挖矿进程
                break
        process.wait()
        # 发送挖矿结束信息
        result_msg = f"Mining process {'completed successfully' if process.returncode ==0 else f'failed with return code {process.returncode}'}."
        output_queue.put(result_msg)
        output_queue.put(None)  # 发送结束标记

    def start_mining(self):
        if self.mining_process and self.mining_process.is_alive():
            print("Already started mining")
            return

        self.settings["mining"] = True
        self.miningpage_frame.pack(fill="both")
        self.homepage_frame.pack_forget()

        mining_command = self.mining_cmd.get()

        # 启动挖矿子进程
        self.mining_process = multiprocessing.Process(
            target=self.capture_output,
            args=(mining_command, self.output_queue, self.settings)
        )
        self.mining_process.start()

    def stop_mining(self):
        """停止挖矿的方法"""
        if self.mining_process and self.mining_process.is_alive():
            self.settings["mining"] = False
            # 等待子进程终止，超时则强制杀死
            self.mining_process.join(timeout=5)
            if self.mining_process.is_alive():
                self.mining_process.kill()
            self.mining_process = None
            # 切换回主页
            self.homepage_frame.pack(fill="both")
            self.miningpage_frame.pack_forget()

• 进程间通信：通过Queue传递挖矿输出，彻底避免跨进程操作Tkinter控件
• 共享状态：用Manager().dict()实现跨进程的状态同步，确保子进程能实时读取停止信号
• 优雅终止：子进程检测到停止信号时，主动调用process.terminate()终止挖矿命令，避免僵尸进程
• UI安全更新：主进程启动守护线程监听队列，所有UI操作都在主进程执行，符合Tkinter的线程安全要求

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