将 uvicorn 的默认线程池调整为 48：

1. api/indexer_app.py（索引服务，端口 6004）在 startup_event() 中添加线程池大小配置使用 anyio.to_thread.current_default_thread_limiter() 设置线程池大小为 48 添加日志记录，便于确认配置是否生效 2. api/app.py（搜索服务，端口 6002）在 startup_event() 中添加线程池大小配置同样设置为 48 个线程添加日志记录

将 uvicorn 的默认线程池调整为 48：
1. api/indexer_app.py（索引服务，端口 6004）在 startup_event() 中添加线程池大小配置使用 anyio.to_thread.current_default_thread_limiter() 设置线程池大小为 48 添加日志记录，便于确认配置是否生效 2. api/app.py（搜索服务，端口 6002）在 startup_event() 中添加线程池大小配置同样设置为 48 个线程添加日志记录
tangwang
1 parent 791a7909
Showing 2 changed files with 18 additions and 0 deletions Show diff stats
api/app.py
api/indexer_app.py
@@ -177,6 +177,15 @@ app.add_middleware(
 @app.on_event("startup")
 async def startup_event():
     """Initialize service on startup."""
+    # Configure thread pool size for uvicorn (default is 40, set to 48)
+    try:
+        import anyio.to_thread
+        limiter = anyio.to_thread.current_default_thread_limiter()
+        limiter.total_tokens = 48
+        logger.info(f"Thread pool size set to {limiter.total_tokens}")
+    except Exception as e:
+        logger.warning(f"Failed to set thread pool size: {e}, using default")
+    
     es_host = os.getenv("ES_HOST", "http://localhost:9200")
     logger.info("Starting E-Commerce Search API (Multi-Tenant)")
     logger.info(f"Elasticsearch Host: {es_host}")
@@ -150,6 +150,15 @@ app = FastAPI(
 @app.on_event("startup")
 async def startup_event():
+    # Configure thread pool size for uvicorn (default is 40, set to 48)
+    try:
+        import anyio.to_thread
+        limiter = anyio.to_thread.current_default_thread_limiter()
+        limiter.total_tokens = 48
+        logger.info(f"Thread pool size set to {limiter.total_tokens}")
+    except Exception as e:
+        logger.warning(f"Failed to set thread pool size: {e}, using default")
+    
     es_host = os.getenv("ES_HOST", "http://localhost:9200")
     logger.info("Starting Indexer API service")
     logger.info(f"Elasticsearch Host: {es_host}")