Update npc_core.py

npc_core.py

@@ -18,14 +18,19 @@ KST = timezone(timedelta(hours=9))
 # ══════════════════════════════════════════════════
 # Global DB Connection Pool — database locked 방지
 # ══════════════════════════════════════════════════
-_db_semaphore = asyncio.Semaphore(5)       # 최대 5개 동시 DB 연결
-_db_write_lock = asyncio.Semaphore(2)      # 최대 2개 동시 쓰기
+_db_semaphore = asyncio.Semaphore(20)       # 일반 DB 연결 (스케줄러+imported함수)
+_db_write_lock = asyncio.Semaphore(2)       # 최대 2개 동시 쓰기
+_db_read_sem = asyncio.Semaphore(30)        # API 읽기 전용 — WAL은 무제한 동시 읽기 지원
 
 @asynccontextmanager
 async def get_db(db_path, write=False, timeout=30.0):
     """Semaphore-controlled DB connection — prevents 'database is locked'"""
     sem = _db_write_lock if write else _db_semaphore
-    async with sem:
+    try:
+        await asyncio.wait_for(sem.acquire(), timeout=15.0)
+    except asyncio.TimeoutError:
+        raise Exception(f"DB {'write' if write else 'read'} semaphore timeout — server busy")
+    try:
         async with aiosqlite.connect(db_path, timeout=timeout) as db:
             await db.execute("PRAGMA busy_timeout=30000")
             await db.execute("PRAGMA journal_mode=WAL")
@@ -35,15 +40,24 @@ async def get_db(db_path, write=False, timeout=30.0):
                     await db.commit()
                 except Exception:
                     pass
+    finally:
+        sem.release()
 
 @asynccontextmanager
-async def get_db_read(db_path, timeout=15.0):
-    """Read-only shortcut — higher concurrency"""
-    async with _db_semaphore:
+async def get_db_read(db_path, timeout=10.0):
+    """Read-only — separate high-concurrency semaphore (WAL supports unlimited reads)"""
+    try:
+        await asyncio.wait_for(_db_read_sem.acquire(), timeout=5.0)
+    except asyncio.TimeoutError:
+        raise Exception("DB read semaphore timeout — server busy")
+    try:
         async with aiosqlite.connect(db_path, timeout=timeout) as db:
-            await db.execute("PRAGMA busy_timeout=15000")
+            await db.execute("PRAGMA busy_timeout=10000")
             await db.execute("PRAGMA journal_mode=WAL")
+            await db.execute("PRAGMA query_only=ON")
             yield db
+    finally:
+        _db_read_sem.release()
 def get_current_time_kst():
     return datetime.now(KST)
 def get_current_date_kst():