diff --git a/src/chat/normal_chat/normal_chat.py b/src/chat/normal_chat/normal_chat.py
index 43abc3e1a..883765c72 100644
--- a/src/chat/normal_chat/normal_chat.py
+++ b/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: