GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 15:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复缓存迭代时的并发问题

Browse Source
This commit is contained in:
jxxghp
2025-08-25 13:11:44 +08:00
parent ffb5823e84
commit 1206f24fa9
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/core/cache.py
+10 -2
View File
@@ -474,7 +474,11 @@ class MemoryBackend(CacheBackend):
if region_cache is None: if region_cache is None:
yield from () yield from ()
return return
for item in region_cache.items(): # 使用锁保护迭代过程，避免在迭代时缓存被修改
with lock:
# 创建快照避免并发修改问题
items_snapshot = list(region_cache.items())
for item in items_snapshot:
yield item yield item
def close(self) -> None: def close(self) -> None:
@@ -603,7 +607,11 @@ class AsyncMemoryBackend(AsyncCacheBackend):
region_cache = self.__get_region_cache(region) region_cache = self.__get_region_cache(region)
if region_cache is None: if region_cache is None:
return return
for item in region_cache.items(): # 使用锁保护迭代过程，避免在迭代时缓存被修改
with lock:
# 创建快照避免并发修改问题
items_snapshot = list(region_cache.items())
for item in items_snapshot:
yield item yield item
async def close(self) -> None: async def close(self) -> None: