Compare commits

..

2 Commits
v1.9.19 ... v1

Author SHA1 Message Date
jxxghp
1336b2136d Merge pull request #4340 from jtcymc/main 2025-05-25 07:59:41 +08:00
shaw
b20e21e700 fix(SearchChain): with 关闭线程池
- 使用 with 语句管理 ThreadPoolExecutor,确保线程池正确关闭
2025-05-25 00:50:34 +08:00

View File

@@ -316,8 +316,10 @@ class SearchChain(ChainBase):
self.progress.update(value=0, self.progress.update(value=0,
text=f"开始搜索,共 {total_num} 个站点 ...", text=f"开始搜索,共 {total_num} 个站点 ...",
key=ProgressKey.Search) key=ProgressKey.Search)
# 结果集
results = []
# 多线程 # 多线程
executor = ThreadPoolExecutor(max_workers=len(indexer_sites)) with ThreadPoolExecutor(max_workers=len(indexer_sites)) as executor:
all_task = [] all_task = []
for site in indexer_sites: for site in indexer_sites:
if area == "imdbid": if area == "imdbid":
@@ -333,8 +335,6 @@ class SearchChain(ChainBase):
mtype=mediainfo.type if mediainfo else None, mtype=mediainfo.type if mediainfo else None,
page=page) page=page)
all_task.append(task) all_task.append(task)
# 结果集
results = []
for future in as_completed(all_task): for future in as_completed(all_task):
finish_count += 1 finish_count += 1
result = future.result() result = future.result()