github/chatgpt-on-wechat
1
0
Fork 0
mirror of https://github.com/zhayujie/chatgpt-on-wechat.git synced 2026-03-19 13:28:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

add concurrency_in_session,request_timeout options

Browse Source
This commit is contained in:
lanvent
2023-04-04 13:33:01 +08:00
parent 5a221848e9
commit 371e38cfa6
3 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
channel/chat_channel.py
View File

@@ -245,7 +245,7 @@ class ChatChannel(Channel):
session_id = context['session_id']
with self.lock:
if session_id not in self.sessions:
self.sessions[session_id] = (queue.Queue(), threading.BoundedSemaphore(1))
self.sessions[session_id] = (queue.Queue(), threading.BoundedSemaphore(conf().get("concurrency_in_session", 1)))
self.sessions[session_id][0].put(context)
# 消费者函数，单独线程，用于从消息队列中取出消息并处理