Ray多进程函数内同步更新PyQt5 QProgressBar进度条问题排查

你的判断完全准确，报错根因有两点：

• Ray的远程任务要求所有传入参数必须支持跨进程序列化，才能在工作进程间传输。PyQt的GUI组件（包括QProgressBar、QApplication实例）是绑定主线程UI事件循环的C++对象封装，本身不支持序列化，这是触发该报错的直接原因，换用multiprocessing时触发pickle错误也是完全相同的原因。
• 就算绕过序列化检测，子进程中拿到的也只是UI对象的独立副本，Qt明确要求所有UI组件的操作必须在创建它的GUI主线程执行，子进程/子线程直接修改UI副本既不会同步到主界面，还会触发跨线程操作UI的崩溃。你代码中尝试将QApplication单例传入子进程的写法本身就违反Qt的基础使用规则。

核心原则：所有UI更新操作必须留在PyQt主线程执行，多进程任务只负责上报执行状态，绝对不直接操作UI组件。针对Ray场景推荐两种稳定实现：

方案1：轮询任务状态更新（最简稳定，优先推荐） #

不需要给远程任务传任何UI相关对象，任务执行完直接返回结果，主进程通过QTimer非阻塞轮询已完成的任务数量，按完成占比更新进度条即可，完全规避序列化问题。
核心代码如下：

from PyQt5.QtCore import QTimer

# 提交任务时不要传入progressBar、QApplication这类UI对象
running_tasks = [myFunction.remote(x, y, z) for x in myList]
total_task_count = len(running_tasks)
# 进度条最大值设为任务总数，5个任务的场景下每完成一个刚好涨20%
self.progressBar.setMaximum(total_task_count)
self.progressBar.setValue(0)

def check_progress():
    # 非阻塞统计已完成的任务数，timeout=0表示不等待立即返回结果
    done_count = 0
    for task in running_tasks:
        if ray.wait([task], timeout=0)[0]:
            done_count += 1
    self.progressBar.setValue(done_count)
    # 全部完成后停止轮询，获取最终结果
    if done_count == total_task_count:
        progress_timer.stop()
        self.results = list(ray.get(running_tasks))

# 每100ms轮询一次，不会阻塞主线程UI事件循环，不需要手动调用processEvents
progress_timer = QTimer()
progress_timer.timeout.connect(check_progress)
progress_timer.start(100)

这个方案不需要修改原有myFunction的业务逻辑，没有额外的线程/进程安全问题，适配所有多进程/多线程场景下的PyQt进度条更新需求。

方案2：Ray Actor上报细粒度进度 #

如果单个任务执行时间很长，需要在任务执行过程中上报分段进度（而非等整个任务跑完才更新），可以用Ray的可序列化Actor句柄维护进度计数，主进程轮询Actor的计数值更新UI。
核心代码如下：

import ray

# 定义进度计数Actor，仅维护进度数值，不持有任何UI对象
@ray.remote
class ProgressCounter:
    def __init__(self, total):
        self.finished_num = 0
        self.total_num = total

    def add_progress(self, step=1):
        self.finished_num += step

    def get_current(self):
        return self.finished_num

# 初始化进度Actor，提交任务时仅传入Actor句柄（天然支持序列化）
progress_counter = ProgressCounter.remote(total_task_count)
running_tasks = [myFunction.remote(x, y, z, progress_counter) for x in myList]
self.progressBar.setMaximum(total_task_count)
self.progressBar.setValue(0)

def update_progress():
    done_count = ray.get(progress_counter.get_current.remote())
    self.progressBar.setValue(done_count)
    if done_count == total_task_count:
        progress_timer.stop()
        self.results = list(ray.get(running_tasks))

progress_timer = QTimer()
progress_timer.timeout.connect(update_progress)
progress_timer.start(100)

对应的myFunction内部，只需要在完成对应进度节点时调用ray.get(progress_counter.add_progress.remote())即可，不需要引入任何PyQt相关逻辑。

• 永远不要在子进程、子线程中直接操作PyQt的UI组件，不管用Ray还是multiprocessing，所有UI修改必须在创建QApplication的主线程执行
• 不要尝试通过共享内存、全局变量传UI对象，GUI组件的线程亲和性决定了这类操作必然引发异常
• 不需要在任务函数中调用QApplication.processEvents()，UI刷新由主线程事件循环自动处理

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