12.23 无效标废标更新

This commit is contained in:
zy123 2024-12-23 10:17:08 +08:00
parent bc0ad7f89d
commit f59c0428b4

View File

@ -276,7 +276,7 @@ def multi_threading(queries, knowledge_name="", file_id="", llm_type=1,need_extr
return [] return []
print("多线程提问starting multi_threading...") print("多线程提问starting multi_threading...")
result_queue = queue.Queue() result_queue = queue.Queue()
with concurrent.futures.ThreadPoolExecutor(max_workers=60) as executor: with concurrent.futures.ThreadPoolExecutor(max_workers=30) as executor:
future_to_index = { future_to_index = {
executor.submit(llm_call, query, knowledge_name, file_id, result_queue, index, llm_type,need_extra): index executor.submit(llm_call, query, knowledge_name, file_id, result_queue, index, llm_type,need_extra): index
for index, query in enumerate(queries) for index, query in enumerate(queries)