Update main.py

main.py

@@ -1,6 +1,5 @@
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI
 from fastapi.responses import JSONResponse
-import asyncio
 import time
 import psutil
 import os
@@ -11,12 +10,8 @@ process = psutil.Process(os.getpid())
 last_cpu_times = process.cpu_times()
 last_time = time.time()
 
-# Queue settings
-MAX_QUEUE_SIZE = 100       # Max number of requests waiting in the queue
-NUM_WORKERS = 20           # Number of concurrent workers
-request_queue = asyncio.Queue(MAX_QUEUE_SIZE)
-
 def get_cpu_percent():
+
     global last_cpu_times, last_time
     now = time.time()
     times = process.cpu_times()
@@ -24,43 +19,19 @@ def get_cpu_percent():
     cpu_used = (times.user - last_cpu_times.user) + (times.system - last_cpu_times.system)
     last_cpu_times = times
     last_time = now
+
     return round((cpu_used / elapsed) * 100, 1)
 
 def simulate_work():
-    total = 0
-    for i in range(500000):
-        total += i
-    return total
-
-async def worker():
-    while True:
-        fut = await request_queue.get()
-        try:
-            result = simulate_work()
-            fut.set_result({"ok": True, "time": int(time.time() * 1000)})
-        except Exception as e:
-            fut.set_exception(e)
-        finally:
-            request_queue.task_done()
 
-# Start worker tasks on startup
-@app.on_event("startup")
-async def startup_event():
-    for _ in range(NUM_WORKERS):
-        asyncio.create_task(worker())
+    start = time.time()
+    while (time.time() - start) < 0.005:
+        pass
 
 @app.get("/")
 async def root():
-    if request_queue.full():
-        # Queue is full, reject request
-        raise HTTPException(status_code=429, detail="Server busy, try again later")
-    
-    # Create a future to get the result from the worker
-    loop = asyncio.get_event_loop()
-    fut = loop.create_future()
-    await request_queue.put(fut)
-    result = await fut
-    return result
+    simulate_work()
+    return {"ok": True, "time": int(time.time() * 1000)}
 
 @app.get("/metrics")
 async def metrics():