Dash应用运行时Worker线程多次启动的问题求助

问题描述 #

我尝试实现一个带有后台工作线程的Dash应用，用线程处理后台任务，同时通过Dash监控进度，但运行代码时发现脚本被加载了两次，导致两个worker线程同时运行。以下是复现代码和输出：

import threading
import time
from threading import Thread

from dash import Dash, html

print("Load script")


def worker():
    print(f"Worker started; Thread {threading.get_ident()}")
    i = 0
    while True:
        time.sleep(5)
        print(f"Thread {threading.get_ident()}, iteration {i}")
        i += 1


if __name__ == "__main__":
    app = Dash("App")
    app.layout = html.Div([html.Div(id='dummy')])
    worker_thread = Thread(target=worker)
    worker_thread.start()
    app.run(debug=True)

运行输出：

Load script
Worker started; Thread 6179811328
Dash is running on http://127.0.0.1:8050/

 * Serving Flask app 'App'
 * Debug mode: on
Load script
Worker started; Thread 6121779200
Thread 6179811328, iteration 0
Thread 6121779200, iteration 0

从输出能看到脚本被第二次加载，额外启动了一个worker线程，想请教这是什么原因，以及如何避免这种情况。

问题原因 #

这是因为你开启了debug=True，而Dash基于Flask框架，Flask的调试模式默认会启动自动重载器（reloader）。

重载器的工作逻辑是：先启动一个"监控进程"负责检测代码变化，再fork出一个"应用进程"来实际运行Dash/Flask服务。这就导致你的脚本被执行了两次：第一次是监控进程加载脚本，第二次是应用进程重新加载脚本，两次都会进入if __name__ == "__main__"代码块，所以启动了两个worker线程。

解决办法 #

这里提供几种不同的解决方案，你可以根据自己的需求选择：

方案1：关闭自动重载器（最简单）

在app.run()中添加use_reloader=False参数，直接禁用重载器，这样脚本只会被加载一次：

if __name__ == "__main__":
    app = Dash("App")
    app.layout = html.Div([html.Div(id='dummy')])
    worker_thread = Thread(target=worker)
    worker_thread.start()
    # 关闭重载器
    app.run(debug=True, use_reloader=False)

优点：操作简单；缺点：失去代码热重载功能，修改代码后需要手动重启应用。

方案2：通过环境变量判断是否启动线程

Flask的重载器会给应用进程设置一个环境变量WERKZEUG_RUN_MAIN，我们可以通过这个变量判断当前进程是不是实际运行服务的进程，只在该进程中启动worker线程：

if __name__ == "__main__":
    import os
    app = Dash("App")
    app.layout = html.Div([html.Div(id='dummy')])
    # 仅在非监控进程的应用进程中启动线程
    if os.environ.get("WERKZEUG_RUN_MAIN") == "true":
        worker_thread = Thread(target=worker)
        worker_thread.start()
    app.run(debug=True)

优点：保留debug模式的热重载功能，同时避免多线程；缺点：依赖Werkzeug的环境变量，属于框架内部细节（不过这个变量长期稳定）。

方案3：绑定Dash应用生命周期启动线程（最规范）

更贴合Web应用的实践是把线程启动逻辑和Dash应用的生命周期绑定，确保只在应用第一次处理请求时启动一次线程，同时设置线程为守护线程避免应用退出时残留：

import threading
import time
from threading import Thread
from dash import Dash, html

print("Load script")

def worker():
    print(f"Worker started; Thread {threading.get_ident()}")
    i = 0
    while True:
        time.sleep(5)
        print(f"Thread {threading.get_ident()}, iteration {i}")
        i += 1

# 标记线程是否已启动，避免重复启动
thread_initialized = False

def start_worker_once():
    global thread_initialized
    if not thread_initialized:
        worker_thread = Thread(target=worker)
        worker_thread.daemon = True  # 守护线程：主进程退出时自动终止
        worker_thread.start()
        thread_initialized = True

if __name__ == "__main__":
    app = Dash("App")
    app.layout = html.Div([html.Div(id='dummy')])
    
    # 绑定到Flask的before_request钩子，每次请求前检查是否启动线程
    @app.server.before_request
    def before_request():
        start_worker_once()
    
    app.run(debug=True)

优点：符合Web应用生命周期管理，即使重载器重启应用，也只会在第一次请求时启动线程，同时守护线程的设置更安全；缺点：代码稍复杂一点，但更健壮。

备注：内容来源于stack exchange，提问作者Christian