当前位置：首页 > 文章列表 > 文章 > python教程 > 多线程安全更新rich进度条方法详解

多线程安全更新rich进度条方法详解

2026-02-01 15:36:43 0浏览收藏

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习文章相关编程知识。下面本篇文章就来带大家聊聊《在多线程中安全更新 rich.progress 进度条，关键在于确保对进度条的访问是线程安全的。由于 rich 库本身并不是为多线程设计的，直接从多个线程中更新进度条可能导致 UI 不一致或崩溃。以下是几种推荐的方法来实现安全的多线程进度更新：✅ 方法一：使用主线程更新（推荐）原理：在主线程中维护一个共享的进度状态变量，由子线程定期更新这个变量，主线程负责实际更新进度条。import threading from rich.progress import Progress import time progress = Progress() shared_progress = 0 def worker(): for i in range(100): time.sleep(0.05) shared_progress = i + 1 # 注意：这里不是赋值，而是通过某种方式传递 def update_progress(): with progress: while shared_progress

多线程下需用 threading.Lock 串行化 rich.progress.update() 调用，主线程创建 Progress 和锁，子线程持 task_id 并在锁内更新；或改用 Live 配合线程安全状态管理；multiprocessing 不支持 Progress 共享。

如何让 rich.progress 在多线程中安全更新进度条

rich.progress 多线程下直接更新会崩溃

直接在多个线程里调用 progress.update() 会导致 RuntimeError: Cannot update progress bar from multiple threads。这是因为 Progress 内部的渲染器（ConsoleRender）不是线程安全的，且进度条状态（如任务计数、已用时间）共享但未加锁。

用 threading.Lock 手动同步更新操作

最轻量、可控性最强的做法：所有对 progress.update() 的调用都包裹在一个全局 threading.Lock 里。这不是“绕过” rich 的限制，而是显式地串行化 UI 更新逻辑。

必须在主线程创建 Progress 实例和 Lock，然后传给子线程
每次调用 progress.update(task_id, advance=1) 前必须 lock.acquire()，完成后 lock.release()（推荐用 with lock:）
不要在锁内做耗时操作（比如文件读写、网络请求），否则会严重拖慢整体进度更新响应
task_id 必须由主线程分配并传入线程，不能在线程里调用 progress.add_task()

from rich.progress import Progress
import threading
import time
progress = Progress()
lock = threading.Lock()
task = progress.add_task("[cyan]Processing...", total=100)
def worker(i):
time.sleep(0.1)  # 模拟工作
with lock:
progress.update(task, advance=1)
threads = [threading.Thread(target=worker, args=(i,)) for i in range(100)]
for t in threads:
t.start()
for t in threads:
t.join()
progress.stop()