Update normal_chat.py

src/chat/normal_chat/normal_chat.py

@@ -304,7 +304,9 @@ class NormalChat:
 
                             semaphore = asyncio.Semaphore(5)
 
-                            async def process_and_acquire(msg_id, message, interest_value, is_mentioned):
+                            async def process_and_acquire(
+                                msg_id, message, interest_value, is_mentioned, semaphore=semaphore
+                            ):
                                 """处理单个兴趣消息并管理信号量"""
                                 async with semaphore:
                                     try: