fastapi中创建线程传递对象

在 FastAPI 中创建线程并传递对象，可以使用 Python 中的 threading 模块。以下是一种基本的方法：

import threading
from fastapi import FastAPI

app = FastAPI()

class MyThread(threading.Thread):
    def __init__(self, obj):
        threading.Thread.__init__(self)
        self.obj = obj

    def run(self):
        # 在此处执行需要在新线程中运行的代码，可以使用 self.obj

@app.get("/")
async def root():
    my_obj = {"data": "hello world"}
    my_thread = MyThread(my_obj)
    my_thread.start()
    return {"message": "Thread started"}

在这个例子中，我们创建了一个自定义的线程类 `MyThread`，它继承自 `threading.Thread`，并且在构造函数中传入了 `obj` 参数。在 `run` 方法中，我们可以执行需要在新线程中运行的代码，并使用传递的 `obj`。在 FastAPI 应用程序中，我们可以在路由处理程序中创建 `MyThread` 实例并启动它，从而在新线程中执行代码。

需要注意的是，如果在新线程中涉及到对 FastAPI 应用程序的请求处理，需要使用异步操作和协程，否则可能会发生阻塞。