import queue
import threading
import time
import uvicorn
import schedule
from fastapi import FastAPI
task_queue = queue.Queue()
app = FastAPI()
@app.get("/")
def read_root():
task_queue.put(1)
return {"Hello": "World"}
def handle_task(task_id: str):
pass
def job():
if task_queue.qsize() > 0:
task_id = task_queue.get()
handle_task(task_id)
def handle_tasks():
schedule.every(1).minute.do(job)
while True:
schedule.run_pending()
time.sleep(1)
if __name__ == "__main__":
task = threading.Thread(target=handle_tasks, args=())
task.start()
uvicorn.run("main:app", host="0.0.0.0", port=8000)
用的是 fastapi,然后我想用一个队列存任务序号,然后再用一个定时任务相当于轮询队列有没有任务,但是现在出错了,我发现两个线程里的队列对象不是同一个
应该怎么写才对