uvicorn 中使用 queue

可以使用 Python 内置的 `queue` 模块来实现在 Uvicorn 中使用队列。下面是一个简单的示例：

import asyncio
import uvicorn
from queue import Queue

q = Queue()

async def worker():
    while True:
        item = await asyncio.get_event_loop().run_in_executor(None, q.get)
        # 处理队列中的任务，这里只是简单地打印出来
        print(f"Processing {item}")
        q.task_done()

async def main():
    # 启动 worker 协程
    asyncio.create_task(worker())
    # 将任务添加到队列中
    for i in range(10):
        q.put(f"Task {i}")
    # 等待队列中的所有任务被处理完
    await q.join()

if __name__ == "__main__":
    uvicorn.run("module_name:app", host="0.0.0.0", port=8000, log_level="info")

在上面的示例中，`worker` 协程不断地从队列中获取任务，并进行处理。`main` 协程将任务添加到队列中，并等待队列中的所有任务被处理完。在 Uvicorn 的 `run` 函数中，将 `module_name` 替换为你的应用程序模块名，例如 `myapp.main`。