如何在Django中运行线程并在视图文件内传递数据

现有代码的问题 #

• 错误调用线程方法：Worker1.start()是直接通过类调用实例方法，必须先实例化Worker1对象再调用start()
• 线程内局部变量无法传递：Worker1.run()里的a=10是局部变量，视图的主线程根本无法访问
• 全局变量value线程不安全：Django处理请求时采用多进程/多线程模式，全局变量会被不同请求篡改，不能用来控制线程启动逻辑

解决方案1：通过线程实例属性传递数据（同步等待场景） #

如果需要等待线程执行完成后再返回响应，可以通过线程实例的属性存储结果，主线程等待线程结束后读取：

修改后的pnet.py #

import threading

class Worker1(threading.Thread):
    def __init__(self):
        super().__init__()
        self.result = None  # 用于存储线程执行结果的实例属性

    def run(self):
        # 执行耗时任务逻辑
        self.result = 10  # 将结果存入实例属性

修改后的视图文件 #

from django.shortcuts import render
from datetime import datetime
from .pnet import Worker1

def home(request):
    worker = Worker1()
    worker.start()
    worker.join()  # 等待线程执行完成
    print(worker.result)  # 此处可获取线程返回的10

    today = datetime.today()
    return render(request, "home.html", {'result': worker.result})

解决方案2：异步线程+线程安全存储（非等待场景） #

如果不想阻塞视图响应，需要线程后台运行并传递数据，可以使用Django缓存（适合跨请求获取结果）：

修改后的pnet.py #

import threading
from django.core.cache import cache

class Worker1(threading.Thread):
    def __init__(self, request_id):
        super().__init__()
        self.request_id = request_id  # 传递唯一请求标识，关联缓存数据

    def run(self):
        result = 10
        # 将结果存入缓存，用request_id作为键
        cache.set(f'thread_result_{self.request_id}', result, timeout=300)

修改后的视图文件 #

from django.shortcuts import render
from datetime import datetime
from django.core.cache import cache
import uuid
from .pnet import Worker1

def home(request):
    request_id = str(uuid.uuid4())  # 生成唯一请求标识
    worker = Worker1(request_id)
    worker.start()

    # 将request_id传给模板，可通过前端轮询等方式获取后续结果
    today = datetime.today()
    return render(request, "home.html", {'request_id': request_id})

# 新增视图用于获取线程执行结果
def get_thread_result(request, request_id):
    result = cache.get(f'thread_result_{request_id}')
    if result is not None:
        return HttpResponse(f"线程结果：{result}")
    return HttpResponse("线程还在执行中")

注意事项 #

• 禁止用全局变量传递线程数据：多请求环境下全局变量会被覆盖，完全不安全
• 后台线程生命周期：如果Django使用WSGI服务器（如Gunicorn），进程重启时后台线程会被终止，长期运行的异步任务建议使用Celery等专业框架
• 线程安全：多线程操作共享数据时，必须使用threading.Lock等锁机制保证数据一致性

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