Django中如何用Python调度器在函数完成后启动线程？视图线程问题求助

嘿，我来帮你搞定这两个问题！先看你视图里的线程为啥没生效——这是个很容易踩的小坑，然后再讲怎么在函数执行完后启动线程。

一、视图中开启线程无效的问题：你漏了start()！ #

你现在的代码只是创建了Thread对象，但没有调用start()方法启动线程，所以线程根本没跑，自然和单线程效果一样。修正后的代码如下：

import threading
import time
from django.http import HttpResponse

def my_view(request):
    # 创建线程对象后，必须调用start()才会启动新线程
    thread = threading.Thread(target=foo)
    thread.start()  # 这行是关键！
    return HttpResponse('ok')

def foo():
    # 模拟10秒阻塞操作
    time.sleep(10)
    print("foo函数执行完毕，耗时10秒")

这样修改后，视图会立刻返回ok给用户，而foo函数会在后台线程里执行，不会阻塞用户请求。

二、如何在某个函数执行完成后启动线程 #

有两种常用方式，根据你的需求选：

1. 直接在目标函数末尾启动（简单直接） #

如果你的需求是“函数A执行完就启动线程跑函数B”，直接在函数A的最后添加线程启动代码就行：

def function_a():
    print("function_a开始执行业务逻辑")
    # 这里写function_a的核心代码...
    time.sleep(3)
    print("function_a执行完成，启动function_b线程")
    
    # 启动线程执行function_b
    threading.Thread(target=function_b).start()

def function_b():
    print("function_b在后台线程启动")
    time.sleep(5)
    print("function_b执行完毕")

2. 用装饰器实现无侵入式触发（更优雅） #

如果不想修改原函数的代码，用装饰器可以实现“原函数执行完自动启动指定线程”的效果，复用性更强：

import threading
import time

# 定义一个装饰器：接受要在后续启动的目标函数
def run_after_thread(target_func):
    def decorator(func):
        def wrapper(*args, **kwargs):
            # 先执行原函数
            result = func(*args, **kwargs)
            # 原函数执行完成后，启动目标线程
            threading.Thread(target=target_func).start()
            return result
        return wrapper
    return decorator

# 给需要触发后续线程的函数加装饰器
@run_after_thread(target_func=function_b)
def function_a():
    print("function_a执行中...")
    time.sleep(3)
    print("function_a执行完成")

def function_b():
    print("function_b后台线程启动")
    time.sleep(5)
    print("function_b执行完毕")

Django中使用线程的注意事项 #

• 数据库连接问题：如果线程里要操作Django ORM，记得先调用close_old_connections()，避免复用已失效的数据库连接：

  def foo():
      from django.db import close_old_connections
      close_old_connections()  # 获取新的数据库连接
      # 后续ORM操作...
  

• 不要传递request对象：request是和当前请求绑定的，线程中可能已经失效，要把需要的数据提前提取出来传入线程函数，而不是直接传request。

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